小编sum*_*tha的帖子

我有以下 dag 设置来运行 2015 年的追赶。对于每个执行日期，任务实例在一分钟内完成。但是，第二天的任务仅在 5 分钟内开始。例如，上午 10:00、上午 10:05、上午 10:10 等。我没有看到为任务实例指定 5 分钟间隔。如何修改 dag 以在前一个实例完成后立即触发？我正在使用气流版本 1.9.0

default_args = {
   'owner': 'ssnehalatha',
   'email': ['ssnehalatha@metromile.com'],
   'depends_on_past': False,
   'start_date': datetime(2015, 1, 1),
   'on_failure_callback': jira_failure_ticket,
   'trigger_rule': 'all_done',
   'retries': 1,
   'pool': 'python_sql_pool'
}

dag = DAG('daily_dag',
           schedule_interval='15 1 * * 0,1,2,3,4,5',
           default_args=default_args,
           dagrun_timeout=timedelta(hours=24),
           catchup=True)