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 <[email protected]> Authored: Tue Sep 19 10:23:38 2017 +0200 Committer: Bolke de Bruin <[email protected]> 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,
