时间戳

首页 > 解决方案 > 如何检查气流测试的输出？

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']

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

气流版本是：

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

标签： airflow

解决方案

如果您使用 Ariflow v1.10，您可以将 taskinstance logger 的传播属性设置为 True，然后日志记录将传播到使用控制台处理程序的根 logger，并打印到 sys.stdout。

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

推荐阅读