Skip to content

Commit

Permalink
[AIRFLOW-6159] Change logging level of the heartbeat message to DEBUG (
Browse files Browse the repository at this point in the history
…#6716)

(cherry picked from commit 9fed459)
  • Loading branch information
kaxil committed Dec 12, 2019
1 parent b06392e commit 2ae17ac
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions airflow/jobs/local_task_job.py
Original file line number Diff line number Diff line change
Expand Up @@ -119,9 +119,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()
Expand Down

0 comments on commit 2ae17ac

Please sign in to comment.