气流外部任务 - 创建DAGS依赖性

Question

我想创建对dag a和dag a的dag依赖。daga具有两个任务：task1和task2。DAG B有3个任务：Task1，Task2和Task3。

我的要求是dag b在dag a task1之后开始。

两个dags每小时运行，dag a ins @every Hours ex：10.00和dag b in @every Hour ex：10.30。

我正在使用气流和操作员外部任务，但它不起作用。

external_dag_id='DAG A',
external_task_id='TASK1',
allowed_states=None,
execution_delta=None,
execution_date_fn=None,

Answer 1

如果在那里检查 execution_delta，则没有，documentation [https://github.com/apache/incubator-airflow/blob/blob/master/master/master/airflow/airflow/airflow/sensors.py##L194]说：

：param execution_delta：上一个执行的时差 查看，默认值与当前任务相同。 对于昨天，使用[阳性！] datetime.timedelta（天= 1）。任何一个 execution_delta或execution_date_fn可以传递给 externaltasksensor，但不是两者。

简短的答案是，由于您在不同时间运行DAG A和DAG B，因此您需要将Execution_delta放置，否则，它假设您的其他DAG同时运行，则在这种情况下，找不到DAG运行可能会得到意外的东西。因此，尝试类似datetime.timedelta（分钟= 30）