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-1031] Replace hard-code to DagRun.ID_PREFIX
Date Tue, 19 Sep 2017 08:23:51 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master eb2f58909 -> ec33ff8f0


[AIRFLOW-1031] Replace hard-code to DagRun.ID_PREFIX

Closes #2613 from morefreeze/patch-1


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

Branch: refs/heads/master
Commit: ec33ff8f090d2dc5e84995f11d3624862c96d1e5
Parents: eb2f589
Author: MoreFreeze <morefreeze@users.noreply.github.com>
Authored: Tue Sep 19 10:23:38 2017 +0200
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Tue Sep 19 10:23:38 2017 +0200

----------------------------------------------------------------------
 airflow/jobs.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/ec33ff8f/airflow/jobs.py
----------------------------------------------------------------------
diff --git a/airflow/jobs.py b/airflow/jobs.py
index 3c79ed9..3e132e3 100644
--- a/airflow/jobs.py
+++ b/airflow/jobs.py
@@ -894,7 +894,7 @@ class SchedulerJob(BaseJob):
 
             if next_run_date and period_end and period_end <= datetime.now():
                 next_run = dag.create_dagrun(
-                    run_id='scheduled__' + next_run_date.isoformat(),
+                    run_id=DagRun.ID_PREFIX + next_run_date.isoformat(),
                     execution_date=next_run_date,
                     start_date=datetime.now(),
                     state=State.RUNNING,


Mime
View raw message