[airflow] branch main updated: Change log level for Zombie detection messages (#20204)

[ka...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kaxilnaik pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 2d79d73  Change log level for Zombie detection messages (#20204)
2d79d73 is described below

commit 2d79d730d7ff9d2c10a2e99a4e728eb831194a97
Author: Kaxil Naik <ka...@gmail.com>
AuthorDate: Fri Dec 10 19:17:00 2021 +0000

    Change log level for Zombie detection messages (#20204)
    
    I missed it in https://github.com/apache/airflow/pull/20118
---
 airflow/dag_processing/manager.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/airflow/dag_processing/manager.py b/airflow/dag_processing/manager.py
index d0de299..408bb48 100644
--- a/airflow/dag_processing/manager.py
+++ b/airflow/dag_processing/manager.py
@@ -1082,7 +1082,7 @@ class DagFileProcessorManager(LoggingMixin):
             )
 
             if zombies:
-                self.log.info("Failing (%s) jobs without heartbeat after %s", len(zombies), limit_dttm)
+                self.log.warning("Failing (%s) jobs without heartbeat after %s", len(zombies), limit_dttm)
 
             self._last_zombie_query_time = timezone.utcnow()
             for ti, file_loc in zombies:
@@ -1091,7 +1091,7 @@ class DagFileProcessorManager(LoggingMixin):
                     simple_task_instance=SimpleTaskInstance(ti),
                     msg=f"Detected {ti} as zombie",
                 )
-                self.log.info("Detected zombie job: %s", request)
+                self.log.error("Detected zombie job: %s", request)
                 self._add_callback_to_queue(request)
                 Stats.incr('zombies_killed')