airflow - 在命令行中测试 Airflow Dag

Question

来自 https://airflow.apache.org/tutorial.html#testing 的 Airflow 手册，我发现我可以运行类似下面的东西来测试特定任务:

airflow test dag_id task_id

当我这样做时，我只收到这条消息:

[2018-07-10 18:29:54,346] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/Grammar.txt
[2018-07-10 18:29:54,367] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/PatternGrammar.txt
[2018-07-10 18:29:54,477] {__init__.py:45} INFO - Using executor SequentialExecutor
[2018-07-10 18:29:54,513] {models.py:189} INFO - Filling up the DagBag from /var/lib/airflow/dags

看起来不像真的在运行它。我被误解了吗？还是有其他方法可以在本地运行 DAG？

Answer 1

我从您链接到的页面的段落中复制了这个示例调用:

# command layout: command subcommand dag_id task_id date

# testing print_date
airflow test tutorial print_date 2015-06-01

# testing sleep
airflow test tutorial sleep 2015-06-01

因此，只需包含如上所示的日期，DAG 任务就会按预期运行。