diff --git a/airflow/jobs/local_task_job.py b/airflow/jobs/local_task_job.py index 3f57d99a1a81c..eda796c7b5b65 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()