时间戳

首页 > 解决方案 > 气流使用外部传感器等待 DAG 结束

python - 气流使用外部传感器等待 DAG 结束

问题描述

我想使用传感器让 DAG 在开始之前等待另一个 DAG。

为此，我生成了以下代码：

ExternalTaskSensor(
        task_id='task_that_wait_the_dag_before_starting',
        external_dag_id='dag_to_wait_it_finishes',
        dag=dag

    ) >> TaskToExecute(
        task_id='task_to_execute,
        dag=dag)

但是当我部署它时，我遇到了错误：

损坏的 DAG：需要参数 ['external_task_id']

这是外部任务的论据。问题是我不想等待特定的任务，我想完全等待 dag。

在文档中我们可以看到：

等待不同 DAG 或不同 DAG 中的任务完成特定 execution_date

如果我可以等待 DAG，为什么需要 external_task id。

标签： pythonairflow

解决方案

推荐阅读