You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by fo...@apache.org on 2018/03/08 12:58:48 UTC
incubator-airflow git commit: [AIRFLOW-2191] Change scheduler
heartbeat logs from info to debug
Repository: incubator-airflow
Updated Branches:
refs/heads/master 044b2c70f -> a5d9d5038
[AIRFLOW-2191] Change scheduler heartbeat logs from info to debug
Closes #3109 from johnarnold/johnar/log1
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/a5d9d503
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/a5d9d503
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/a5d9d503
Branch: refs/heads/master
Commit: a5d9d5038b3ab59dcc1f64a1c161fb63f41c58cf
Parents: 044b2c7
Author: John Arnold (AZURE) <jo...@microsoft.com>
Authored: Thu Mar 8 13:58:06 2018 +0100
Committer: Fokko Driesprong <fo...@godatadriven.com>
Committed: Thu Mar 8 13:58:06 2018 +0100
----------------------------------------------------------------------
airflow/jobs.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/a5d9d503/airflow/jobs.py
----------------------------------------------------------------------
diff --git a/airflow/jobs.py b/airflow/jobs.py
index 5a2ab5b..d70ab85 100644
--- a/airflow/jobs.py
+++ b/airflow/jobs.py
@@ -1626,7 +1626,7 @@ class SchedulerJob(BaseJob):
self.clear_nonexistent_import_errors(known_file_paths=known_file_paths)
# Kick of new processes and collect results from finished ones
- self.log.info("Heartbeating the process manager")
+ self.log.debug("Heartbeating the process manager")
simple_dags = processor_manager.heartbeat()
if self.using_sqlite:
@@ -1661,7 +1661,7 @@ class SchedulerJob(BaseJob):
(State.SCHEDULED,))
# Call heartbeats
- self.log.info("Heartbeating the executor")
+ self.log.debug("Heartbeating the executor")
self.executor.heartbeat()
# Process events from the executor
@@ -1671,7 +1671,7 @@ class SchedulerJob(BaseJob):
time_since_last_heartbeat = (timezone.utcnow() -
last_self_heartbeat_time).total_seconds()
if time_since_last_heartbeat > self.heartrate:
- self.log.info("Heartbeating the scheduler")
+ self.log.debug("Heartbeating the scheduler")
self.heartbeat()
last_self_heartbeat_time = timezone.utcnow()