示例DAG无限期地陷入“运行”状态

在我第一次进入气流时，我试图运行安装时附带的示例DAGS之一。这是v.1.8.0。下面是我的步骤：示例DAG无限期地陷入“运行”状态

$ 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

达格状态保持“运行”很长一段时间（至少20分钟到现在），虽然从这项任务的快速检查应采取几秒钟的事。我如何解决这个问题？我怎样才能看到它卡在哪一步？

来源

2017-04-19 gcbenison

你可以分享你的代码吗？如果我们知道你在做什么，它会更容易回答 –

我没有添加超过v.1.8.0安装提供的任何代码。 – gcbenison

哦！检查schedule_interval和start_date，如果日期和时间安排在将来，脚本只会在特定的日期和时间触发 –

要运行任何的DAG，你需要确保两个进程正在运行：

airflow webserver
airflow scheduler

如果你只有airflow webserver运行，用户界面将显示的DAG为running ，但是如果您单击DAG，则它的任何任务都不是running或scheduled，而是Null状态。这意味着他们正在等待被airflow scheduler接收。如果airflow scheduler未运行，您将永远处于此状态，因为这些任务从未被执行。

来源

2018-01-16 18:11:26

不知道为什么这个答案downvoted，但这实际上工作。谢谢！ –

示例DAG无限期地陷入“运行”状态

回答

相关问题