气流外部任务传感器戳到另一个dag所有的时间

Question

我想用ExternalTaskSensor

TaskSensor = ExternalTaskSensor(
                            task_id='TaskSensor',
                            external_dag_id='datamart_OTT_CMS_v1',
                             external_task_id="end",
                             allowed_states=None,
                             execution_delta=None,
                             execution_date_fn=None,
                                dag=dag)

我根据a写一个dag B。当dag a结束（成功）然后dag B将运行。当我发现达格在跑的时候。

为什么？我错过什么了吗？在

Answer 1

这是意料之中的行为。{CMS{1}完成CDU的“数据集市”任务。默认情况下，它每分钟检查一次，但您可以通过在传感器上设置poke_interval（秒）来缩短此间隔。在

也许你要找的是TriggerDagRunOperator。因此，不依赖轮询，您可以在daga的末尾使用这个操作符来触发dagb的运行