We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f73b066 commit 30189b7Copy full SHA for 30189b7
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
@@ -505,9 +505,9 @@ def _change_state(
505
if state is None:
506
from airflow.models.taskinstance import TaskInstance
507
508
- condition = TaskInstance.filter_for_tis([key])
509
- if condition is not None:
510
- state = session.scalar(select(TaskInstance.state).where(condition))
+ filter_for_tis = TaskInstance.filter_for_tis([key])
+ if filter_for_tis is not None:
+ state = session.scalar(select(TaskInstance.state).where(filter_for_tis))
511
else:
512
state = None
513
state = TaskInstanceState(state) if state else None
0 commit comments