python - Airflow - 禁用心跳日志

Question

对于每次心跳，我的日志都充满了无用的消息。

[2019-11-27 21:32:47,890] {{logging_mixin.py:112}} INFO - [2019-11-27 21:32:47,889] {local_task_job.py:124} WARNING - Time since last heartbeat(0.02 s) < heartrate(5.0 s), sleeping for 4.983326 s
[2019-11-27 21:32:52,921] {{logging_mixin.py:112}} INFO - [2019-11-27 21:32:52,921] {local_task_job.py:124} WARNING - Time since last heartbeat(0.02 s) < heartrate(5.0 s), sleeping for 4.984673 s
[2019-11-27 21:32:57,949] {{logging_mixin.py:112}} INFO - [2019-11-27 21:32:57,949] {local_task_job.py:124} WARNING - Time since last heartbeat(0.01 s) < heartrate(5.0 s), sleeping for 4.985953 s
[2019-11-27 21:33:02,980] {{logging_mixin.py:112}} INFO - [2019-11-27 21:33:02,980] {local_task_job.py:124} WARNING - Time since last heartbeat(0.02 s) < heartrate(5.0 s), sleeping for 4.984688 s
[2019-11-27 21:33:08,008] {{logging_mixin.py:112}} INFO - [2019-11-27 21:33:08,008] {local_task_job.py:124} WARNING - Time since last heartbeat(0.01 s) < heartrate(5.0 s), sleeping for 4.987069 s
[2019-11-27 21:33:13,041] {{logging_mixin.py:112}} INFO - [2019-11-27 21:33:13,041] {local_task_job.py:124} WARNING - Time since last heartbeat(0.02 s) < heartrate(5.0 s), sleeping for 4.984275 s
[2019-11-27 21:33:18,072] {{logging_mixin.py:112}} INFO - [2019-11-27 21:33:18,071] {local_task_job.py:124} WARNING - Time since last heartbeat(0.01 s) < heartrate(5.0 s), sleeping for 4.986545 s
[2019-11-27 21:33:23,101] {{logging_mixin.py:112}} INFO - [2019-11-27 21:33:23,100] {local_task_job.py:124} WARNING - Time since last heartbeat(0.02 s) < heartrate(5.0 s), sleeping for 4.984889 s
[2019-11-27 21:33:28,130] {{logging_mixin.py:112}} INFO - [2019-11-27 21:33:28,130] {local_task_job.py:124} WARNING - Time since last heartbeat(0.01 s) < heartrate(5.0 s), sleeping for 4.986234 s
[2019-11-27 21:33:33,160] {{logging_mixin.py:112}} INFO - [2019-11-27 21:33:33,160] {local_task_job.py:124} WARNING - Time since last heartbeat(0.01 s) < heartrate(5.0 s), sleeping for 4.986669 s

我们的日志现在太嘈杂而无用。 我们如何禁用这些 ?将日志级别更改为类似 logging.WARN 的内容不是一个选项，因为我们在 INFO 上有很多实际有用的信息。等级。
编辑:我使用的是 Airflow 1.10.6

Answer 1

目前，无法禁用它。我创建了一个 PR将日志级别更改为 DEBUG。不幸的是，直到下一个版本( 1.10.7 )才能使用。

短期解决方案是手动应用 PR 中的更改。到您的 Airflow 安装。