airflow有关的问题


重新启动由主管管理的Apache Airflow

概述
我将Apache Airflow从1.9.0更新到1.10.10。我正在通过主管管理气流流程/组件。我有一个ansible-playbook,每次我部署c时都会重新启动这些过程。


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

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


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

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