airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (AIRFLOW-582) ti.get_dagrun() should not filter on start_date
Date Fri, 28 Oct 2016 22:21:58 GMT

    [ https://issues.apache.org/jira/browse/AIRFLOW-582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15616774#comment-15616774
] 

ASF subversion and git services commented on AIRFLOW-582:
---------------------------------------------------------

Commit 1660aa024a40bf1fe4b650dd3c9044707f34f089 in incubator-airflow's branch refs/heads/master
from [~btallman@gmail.com]
[ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=1660aa0 ]

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

Closes #1844 from btallman/ti_get_dagrun


> ti.get_dagrun() should not filter on start_date
> -----------------------------------------------
>
>                 Key: AIRFLOW-582
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-582
>             Project: Apache Airflow
>          Issue Type: Bug
>            Reporter: Ben Tallman
>
> The filter in ti.get_dagrun should not include start_date, it should only search on execution_date.
>     @provide_session
>     def get_dagrun(self, session):
>         """
>         Returns the DagRun for this TaskInstance
>         :param session:
>         :return: DagRun
>         """
>         dr = session.query(DagRun).filter(
>             DagRun.dag_id == self.dag_id,
>             DagRun.execution_date == self.execution_date,
>             DagRun.start_date == self.start_date
>         ).first()
>         return dr



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message