airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-812] Fix the scheduler termination bug.
Date Fri, 27 Jan 2017 10:44:36 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/v1-8-test 40442e58f -> 1060ade28


[AIRFLOW-812] Fix the scheduler termination bug.

When checking max-runs for dag_files the scheduler
would stop immediately if there were no files.

Closes #2027 from fenglu-g/master

(cherry picked from commit f8d8ddac08dbec90b240a6b8670be9bd650dfb3b)
Signed-off-by: Bolke de Bruin <bolke@xs4all.nl>


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

Branch: refs/heads/v1-8-test
Commit: 1060ade28119a5e1eb81fc331689bffd37b351b3
Parents: 40442e5
Author: Feng Lu <fenglu@fengcloud.hot.corp.google.com>
Authored: Fri Jan 27 10:45:50 2017 +0100
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Fri Jan 27 11:44:20 2017 +0100

----------------------------------------------------------------------
 airflow/utils/dag_processing.py | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/1060ade2/airflow/utils/dag_processing.py
----------------------------------------------------------------------
diff --git a/airflow/utils/dag_processing.py b/airflow/utils/dag_processing.py
index 6209946..ef1c1ed 100644
--- a/airflow/utils/dag_processing.py
+++ b/airflow/utils/dag_processing.py
@@ -634,6 +634,8 @@ class DagFileProcessorManager(LoggingMixin):
         """
         :return: whether all file paths have been processed max_runs times
         """
+        if not self._file_paths:  # No dag file is present.
+            return False
         for file_path in self._file_paths:
             if self._run_count[file_path] != self._max_runs:
                 return False


Mime
View raw message