我正在运行 Airflow 并尝试迭代我们从命令行构建的某些任务。
运行气流网络服务器时,一切都按预期工作。但是当我跑步时airflow backfill dag task '2017-08-12'
,气流返回:
[2017-08-15 02:52:55,639] {__init__.py:57} INFO - Using executor LocalExecutor
[2017-08-15 02:52:56,144] {models.py:168} INFO - Filling up the DagBag from /usr/local/airflow/dags
2017-08-15 02:52:59,055 - airflow.jobs.BackfillJob - INFO - Backfill done. Exiting
...并且实际上并没有运行dag。
当使用airflow test
or airflow run
(即涉及运行任务而不是 dag 的命令)时,它按预期工作
我犯了一个基本的错误吗?我该怎么做才能从这里调试?
谢谢