You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2017/09/13 13:25:08 UTC
incubator-airflow git commit: [AIRFLOW-1606] Use non static
DAG.sync_to_db
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 <bo...@xs4all.nl>
Authored: Wed Sep 13 15:24:58 2017 +0200
Committer: Bolke de Bruin <bo...@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]