如何检查气流测试的输出？

Question

我尝试了气流教程 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']

这就是所有的输出，而我的输出不在那里。

气流版本是：

? 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可以做到这一点。