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

Closes apache#2613 from morefreeze/patch-1 (cherry picked from commit ec33ff8) Signed-off-by: Bolke de Bruin <[email protected]>
soundcloud · Sep 19, 2017 · aa3844f · aa3844f
1 parent af40508
commit aa3844f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/jobs.py b/airflow/jobs.py
@@ -894,7 +894,7 @@ def create_dag_run(self, dag, session=None):
 
             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,