airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1606] Use non static DAG.sync_to_db
Date Wed, 13 Sep 2017 13:25:08 GMT
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 <bolke@xs4all.nl>
Authored: Wed Sep 13 15:24:58 2017 +0200
Committer: Bolke de Bruin <bolke@xs4all.nl>
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]


Mime
View raw message