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 51064ba2409 Fix mypy error in `scheduler_job_runner.py` (#59204)
51064ba2409 is described below
commit 51064ba24094a943a1e1916a71899531303b2256
Author: Vincent <[email protected]>
AuthorDate: Mon Dec 8 14:59:19 2025 -0500
Fix mypy error in `scheduler_job_runner.py` (#59204)
---
airflow-core/src/airflow/jobs/scheduler_job_runner.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py
b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
index e50af60db88..5d8df8e970e 100644
--- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py
+++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
@@ -1679,6 +1679,8 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
select(AssetPartitionDagRun).where(AssetPartitionDagRun.created_dag_run_id.is_(None))
)
for apdr in apdrs:
+ if TYPE_CHECKING:
+ assert apdr.target_dag_id
partition_dag_ids.add(apdr.target_dag_id)
dag = _get_current_dag(dag_id=apdr.target_dag_id, session=session)
if not dag:
