相关疑难解决方法(0)

现在,我的DAG中的节点在该DAG的其余节点完成之前进入第二天的任务.有没有办法等待DAG的其余部分完成,然后才能进入第二天的DAG循环？

(我确实将depends_on_previous视为真,但在这种情况下不起作用)

我的DAG看起来像这样:

               O
               l
               V
O -> O -> O -> O -> O

另外,dag的树视图]

我希望DAG中的所有任务在下一次运行的第一个任务执行之前全部完成。

我有max_active_runs = 1，但是这仍然发生。

default_args = {
'depends_on_past': True,
'wait_for_downstream': True,
'max_active_runs': 1,
'start_date': datetime(2018, 03, 04),
'owner': 'tin.nguyen',
'email': ['tin.nguyen@example.com'],
'email_on_failure': True,
'email_on_retry': False,
'retries': 3,
'retry_delay': timedelta(minutes=4)
}

dag = DAG('example', default_args=default_args, schedule_interval = schedule_interval)

（我的所有任务都取决于上一个任务。气流版本为1.8.0）

谢谢