airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a..@apache.org
Subject incubator-airflow git commit: [AIRFLOW-2199] Fix invalid reference to logger
Date Thu, 08 Mar 2018 14:39:13 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master a5d9d5038 -> 7cc6d8a56


[AIRFLOW-2199] Fix invalid reference to logger

This should be log instead of logger. Somewhere it
went wrong with
the refactoring of the code.

This patch had conflicts when merged, resolved by
Committer: Ash Berlin-Taylor
<ash_github@firemirror.com>

Closes #3114 from Fokko/fd-fix-logger


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/7cc6d8a5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/7cc6d8a5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/7cc6d8a5

Branch: refs/heads/master
Commit: 7cc6d8a5645b8974f07e132cc3c4820e880fd3ce
Parents: a5d9d50
Author: Fokko Driesprong <fokkodriesprong@godatadriven.com>
Authored: Thu Mar 8 14:38:40 2018 +0000
Committer: Ash Berlin-Taylor <ash_github@firemirror.com>
Committed: Thu Mar 8 14:38:40 2018 +0000

----------------------------------------------------------------------
 airflow/jobs.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/7cc6d8a5/airflow/jobs.py
----------------------------------------------------------------------
diff --git a/airflow/jobs.py b/airflow/jobs.py
index d70ab85..13fc2a2 100644
--- a/airflow/jobs.py
+++ b/airflow/jobs.py
@@ -1162,8 +1162,8 @@ class SchedulerJob(BaseJob):
                 if task_concurrency is not None:
                     num_running = task_concurrency_map[((task_instance.dag_id, task_instance.task_id))]
                     if num_running >= task_concurrency:
-                        self.logger.info("Not executing %s since the task concurrency for
this task"
-                                         " has been reached.", task_instance)
+                        self.log.info("Not executing %s since the task concurrency for"
+                                      " this task has been reached.", task_instance)
                         continue
                     else:
                         task_concurrency_map[(task_instance.dag_id, task_instance.task_id)]
+= 1


Mime
View raw message