Repository: incubator-airflow Updated Branches: refs/heads/master 028b3b88f -> 6ac2963fb
[AIRFLOW-1606] Use non static DAG.sync_to_db Finalizes refactor where one line was missed. Closes #2606 from bolkedebruin/AIRFLOW-1606 Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/6ac2963f Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/6ac2963f Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/6ac2963f Branch: refs/heads/master Commit: 6ac2963fb4bf61774ed856ed7f0a922acf9487be Parents: 028b3b8 Author: Bolke de Bruin <[email protected]> Authored: Wed Sep 13 15:24:58 2017 +0200 Committer: Bolke de Bruin <[email protected]> Committed: Wed Sep 13 15:24:58 2017 +0200 ---------------------------------------------------------------------- airflow/jobs.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/6ac2963f/airflow/jobs.py ---------------------------------------------------------------------- diff --git a/airflow/jobs.py b/airflow/jobs.py index 904609c..f855320 100644 --- a/airflow/jobs.py +++ b/airflow/jobs.py @@ -1712,9 +1712,8 @@ class SchedulerJob(BaseJob): return [] # Save individual DAGs in the ORM and update DagModel.last_scheduled_time - sync_time = datetime.now() for dag in dagbag.dags.values(): - models.DAG.sync_to_db(dag, dag.owner, sync_time) + dag.sync_to_db() paused_dag_ids = [dag.dag_id for dag in dagbag.dags.values() if dag.is_paused]
