airflow有关的问题


使用TaskInstance的通过XCOMM从PythonOperator提取返回值

我试图写一些气流集成测试,在那里我模仿gcs_list_operator通过从一个自定义的PythonOperator返回一个文件列表,然后传递给一个PythonBranchOperator thro.


如何获取来自不同dag的所有失败任务的列表

我们有以下命令,我们可以清除失败的任务并在一次尝试中重新运行它们
气流清除 [-s START_DATE] [-e END_DATE] -- only_failed dag_id
我们有什么办法可以得到信息吗.