Skip to content

Commit

Permalink
no alias
Browse files Browse the repository at this point in the history
  • Loading branch information
dstandish committed Mar 19, 2024
1 parent efc2582 commit fbe138d
Showing 1 changed file with 5 additions and 6 deletions.
11 changes: 5 additions & 6 deletions airflow/models/taskinstance.py
Original file line number Diff line number Diff line change
Expand Up @@ -1842,15 +1842,14 @@ def key(self) -> TaskInstanceKey:
@staticmethod
@internal_api_call
def _set_state(ti: TaskInstance | TaskInstancePydantic, state, session: Session) -> bool:
TI = TaskInstance
if not isinstance(ti, TaskInstance):
ti = (
session.query(TI)
session.query(TaskInstance)
.filter(
TI.task_id == ti.task_id,
TI.dag_id == ti.dag_id,
TI.run_id == ti.run_id,
TI.map_index == ti.map_index,
TaskInstance.task_id == ti.task_id,
TaskInstance.dag_id == ti.dag_id,
TaskInstance.run_id == ti.run_id,
TaskInstance.map_index == ti.map_index,
)
.one()
)
Expand Down

0 comments on commit fbe138d

Please sign in to comment.