airflow - 示例DAG无限期陷入 “running”状态

Question

在我第一次接触气流时，我尝试运行安装随附的示例DAGS之一。这是v.1.8.0。这是我的步骤:

$ airflow trigger_dag example_bash_operator
[2017-04-19 15:32:38,391] {__init__.py:57} INFO - Using executor SequentialExecutor
[2017-04-19 15:32:38,676] {models.py:167} INFO - Filling up the DagBag from /Users/gbenison/software/kludge/airflow/dags
[2017-04-19 15:32:38,947] {cli.py:185} INFO - Created <DagRun example_bash_operator @ 2017-04-19 15:32:38: manual__2017-04-19T15:32:38, externally triggered: True>
$ airflow dag_state example_bash_operator '2017-04-19 15:32:38'
[2017-04-19 15:33:12,918] {__init__.py:57} INFO - Using executor SequentialExecutor
[2017-04-19 15:33:13,229] {models.py:167} INFO - Filling up the DagBag from /Users/gbenison/software/kludge/airflow/dags
running

dag状态长时间(到目前为止至少20分钟)保持“运行”状态，尽管从快速检查此任务可能需要几秒钟的时间。我该如何解决？我如何看到它停留在哪一步？

Answer 1

要运行任何DAG，您需要确保两个进程正在运行:

airflow webserver

airflow scheduler

如果仅运行 airflow webserver，则UI会将DAG显示为 running，但如果单击DAG，则其任务实际上都不是 running或 scheduled，而是处于 Null状态。
这意味着它们正在等待被 airflow scheduler拾取。如果 airflow scheduler没有运行，您将永远处于这种状态，因为永远不会选择执行任务。

此外，请确保将DAG的DAG View 中的切换按钮切换为“ON”。否则，如果您手动触发它，它将不会被调度程序接收。