airflow - 如何检查 Airflow 测试的输出？

Question

我尝试了 Airflow 教程 DAG，它与调度程序一起使用，我可以看到调度运行生成的日志。但是如果我使用命令行测试，我没有看到输出:

airflow test my_tutorial_2 templated 2018-09-08
[2018-09-10 15:41:43,121] {__init__.py:51} INFO - Using executor SequentialExecutor
[2018-09-10 15:41:43,281] {models.py:258} INFO - Filling up the DagBag from /Users/xiang/Documents/BigData/airflow/dags
[2018-09-10 15:41:43,338] {example_kubernetes_operator.py:54} WARNING - Could not import KubernetesPodOperator: No module named 'kubernetes'
[2018-09-10 15:41:43,339] {example_kubernetes_operator.py:55} WARNING - Install kubernetes dependencies with:     pip install airflow['kubernetes']

这就是所有的输出，我的输出没有。

Airflow 版本为:

▶ pip list
Package          Version
---------------- ---------
alembic          0.8.10
apache-airflow   1.10.0

Answer 1

如果您使用Ariflow v1.10，您可以将taskinstance logger的propagate属性设置为True，那么日志记录将被传播到使用console handler的root logger，并打印到sys.stdout。

添加 ti.log.propagate = True在第 589 行之后到 site-packages/airflow/bin/cli.py 可以做到这一点。