This is an automated email from the ASF dual-hosted git repository.
vincbeck pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 734960df055 Fix mypy static errors in standard provider (#57762)
734960df055 is described below
commit 734960df055b09cfa52a905664acfd576a504cc9
Author: Vincent <[email protected]>
AuthorDate: Mon Nov 3 16:01:41 2025 -0500
Fix mypy static errors in standard provider (#57762)
---
.../standard/src/airflow/providers/standard/sensors/external_task.py | 3 ++-
.../standard/src/airflow/providers/standard/triggers/external_task.py | 4 ++--
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git
a/providers/standard/src/airflow/providers/standard/sensors/external_task.py
b/providers/standard/src/airflow/providers/standard/sensors/external_task.py
index 62a1ed1d6e7..5bfe97b4143 100644
--- a/providers/standard/src/airflow/providers/standard/sensors/external_task.py
+++ b/providers/standard/src/airflow/providers/standard/sensors/external_task.py
@@ -479,7 +479,8 @@ class ExternalTaskSensor(BaseSensorOperator):
if not dag_to_wait:
raise ExternalDagNotFoundError(f"The external DAG
{self.external_dag_id} does not exist.")
- if not os.path.exists(correct_maybe_zipped(dag_to_wait.fileloc)):
+ path = correct_maybe_zipped(dag_to_wait.fileloc)
+ if not path or not os.path.exists(path):
raise ExternalDagDeletedError(f"The external DAG
{self.external_dag_id} was deleted.")
if self.external_task_ids:
diff --git
a/providers/standard/src/airflow/providers/standard/triggers/external_task.py
b/providers/standard/src/airflow/providers/standard/triggers/external_task.py
index 7908b64cde5..5295963c1d9 100644
---
a/providers/standard/src/airflow/providers/standard/triggers/external_task.py
+++
b/providers/standard/src/airflow/providers/standard/triggers/external_task.py
@@ -269,7 +269,7 @@ class DagStateTrigger(BaseTrigger):
def count_dags(self, *, session: Session = NEW_SESSION) -> int:
"""Count how many dag runs in the database match our criteria."""
_dag_run_date_condition = (
- DagRun.run_id.in_(self.run_ids)
+ DagRun.run_id.in_(self.run_ids or [])
if AIRFLOW_V_3_0_PLUS
else DagRun.execution_date.in_(self.execution_dates)
)
@@ -283,4 +283,4 @@ class DagStateTrigger(BaseTrigger):
)
)
result = session.execute(stmt).scalar()
- return typing.cast("int", result or 0)
+ return result or 0
