草庐IT

ExternalTask

全部标签

python - Airflow ExternalTask​​Sensor 卡住了

我正在尝试使用ExternalTask​​Sensor,它卡在戳另一个DAG的任务,而该任务已经成功完成。在这里,第一个DAG“a”完成了它的任务,然后应该触发通过ExternalTask​​Sensor的第二个DAG“b”。相反,它会卡在查找a.first_task上。第一个DAG:importdatetimefromairflowimportDAGfromairflow.operators.python_operatorimportPythonOperatordag=DAG(dag_id='a',default_args={'owner':'airflow','start_date