From 33b05bf1a9f3b2494c0c6e4cdaf8f692c372d4b2 Mon Sep 17 00:00:00 2001 From: kaxil Date: Mon, 2 Dec 2019 22:57:14 +0000 Subject: [PATCH] [AIRFLOW-6159] Change logging level of the heartbeat message to DEBUG --- airflow/jobs/local_task_job.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/airflow/jobs/local_task_job.py b/airflow/jobs/local_task_job.py index 3f57d99a1a81cc..eda796c7b5b652 100644 --- a/airflow/jobs/local_task_job.py +++ b/airflow/jobs/local_task_job.py @@ -115,9 +115,9 @@ def signal_handler(signum, frame): if time_since_last_heartbeat < self.heartrate: sleep_for = self.heartrate - time_since_last_heartbeat - self.log.info("Time since last heartbeat(%.2f s) < heartrate(%s s)" - ", sleeping for %s s", time_since_last_heartbeat, - self.heartrate, sleep_for) + self.log.debug("Time since last heartbeat(%.2f s) < heartrate(%s s)" + ", sleeping for %s s", time_since_last_heartbeat, + self.heartrate, sleep_for) time.sleep(sleep_for) finally: self.on_kill()