[AIRFLOW-582] Fixes TI.get_dagrun filter (removes start_date)
Closes #1844 from btallman/ti_get_dagrun
This commit is contained in:
Родитель
6f4704a447
Коммит
1660aa024a
|
@ -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
|
||||
|
|
Загрузка…
Ссылка в новой задаче