Repository: incubator-airflow Updated Branches: refs/heads/v1-9-test af4050847 -> aa3844f4e
[AIRFLOW-1031] Replace hard-code to DagRun.ID_PREFIX Closes #2613 from morefreeze/patch-1 (cherry picked from commit ec33ff8f090d2dc5e84995f11d3624862c96d1e5) Signed-off-by: Bolke de Bruin <bo...@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/aa3844f4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/aa3844f4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/aa3844f4 Branch: refs/heads/v1-9-test Commit: aa3844f4e6b93bdc62fc679df1054c8cf424576d Parents: af40508 Author: MoreFreeze <morefre...@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:51 2017 +0200 ---------------------------------------------------------------------- airflow/jobs.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/aa3844f4/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,
