airflow - 如何显示 DockerOperator 的日志输出？

Question

我有一个 DockerOperator 工作，但是当我使用“Airflow 测试”运行它时， Airflow 没有像 PythonOperator 或 BashOperator 那样显示我的 DockerOperator 的任何日志记录语句。但是我可以看到运行相同任务的日志记录语句。我如何使记录器对“Airflow 测试”也可见？

Answer 1

将以下内容添加到我的执行模块中会为我显示 DockerOperator 中的日志。

import logging
import sys

logging.basicConfig(stream=sys.stdout, level=logging.INFO)