You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by as...@apache.org on 2018/03/08 14:39:13 UTC
incubator-airflow git commit: [AIRFLOW-2199] Fix invalid reference to
logger
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
<as...@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 <fo...@godatadriven.com>
Authored: Thu Mar 8 14:38:40 2018 +0000
Committer: Ash Berlin-Taylor <as...@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