You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2017/09/19 08:23:51 UTC
incubator-airflow git commit: [AIRFLOW-1031] Replace hard-code to
DagRun.ID_PREFIX
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 <mo...@users.noreply.github.com>
Authored: Tue Sep 19 10:23:38 2017 +0200
Committer: Bolke de Bruin <bo...@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,