python - Airflow DAG 正在运行，但未执行任务

我正在使用从流行的puckel 气流 docker 映像中分叉的 Airflow 1.10.2，并使用 CLI 来操作它阅读文档。我创建了一个 DAG，当我通过 UI 触发它时它会成功执行。但是当我使用命令行触发 DAG 时，DAG 状态变为 RUNNING 但任务从未执行。

对于下图的参考，DAG 的 ID 是xcom_4_modules_ver_5

通过预定进程运行 DAG 并通过 UI 手动触发后，我airflow list_dag_runs xcom_4_modules_ver_5在 CLI 上执行以检查 DAG 运行的状态。DAG 已成功执行，并将预期的输出写入日志文件。这对应于 ID 1 和 2。

但是，在airflow trigger_dag -sd /usr/local/airflow/airflow/dags/ -r CLI-RUN-TEST xcom_4_modules_ver_5从 UI 执行触发 DAG 的命令后，状态永远是 RUNNING。对应于下图中的 ID 3。

我转到 UI 中的树视图，发现没有组件执行了很长时间。

前两个绿色列对应于运行 ID 1 和 2，而第三列映射到运行 ID 3。

和airflow scheduler开启airflow webserver。

会要求这里的气流大师向我提出建议。

标签： pythontaskcommand-line-interfaceairflowdirected-acyclic-graphs