airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From san...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-582] Fixes TI.get_dagrun filter (removes start_date)
Date Fri, 28 Oct 2016 22:21:25 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master 6f4704a44 -> 1660aa024


[AIRFLOW-582] Fixes TI.get_dagrun filter (removes start_date)

Closes #1844 from btallman/ti_get_dagrun


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/1660aa02
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/1660aa02
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/1660aa02

Branch: refs/heads/master
Commit: 1660aa024a40bf1fe4b650dd3c9044707f34f089
Parents: 6f4704a
Author: Benjamin Tallman <btallman@gmail.com>
Authored: Fri Oct 28 15:21:16 2016 -0700
Committer: Siddharth Anand <siddharthanand@yahoo.com>
Committed: Fri Oct 28 15:21:16 2016 -0700

----------------------------------------------------------------------
 airflow/models.py | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/1660aa02/airflow/models.py
----------------------------------------------------------------------
diff --git a/airflow/models.py b/airflow/models.py
index e0a2cda..91662de 100755
--- a/airflow/models.py
+++ b/airflow/models.py
@@ -1135,8 +1135,7 @@ class TaskInstance(Base):
         """
         dr = session.query(DagRun).filter(
             DagRun.dag_id == self.dag_id,
-            DagRun.execution_date == self.execution_date,
-            DagRun.start_date == self.start_date
+            DagRun.execution_date == self.execution_date
         ).first()
 
         return dr


Mime
View raw message