Skip to content

Commit 0ff46f9

Browse files
committed
Update DagSkippedIntervalsCallbackRequest docstring, replace .in_() with ==
1 parent 484c1a4 commit 0ff46f9

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

airflow-core/src/airflow/callbacks/callback_requests.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,7 @@ class DagCallbackRequest(BaseCallbackRequest):
176176

177177

178178
class DagSkippedIntervalsCallbackRequest(BaseCallbackRequest):
179-
"""A Class with information about the skipped intervals DAG callback to be executed."""
179+
"""Store skipped intervals callback data for execution by the Dag processor."""
180180

181181
dag_id: str
182182
skipped_interval_count: int

airflow-core/src/airflow/jobs/scheduler_job_runner.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2416,7 +2416,7 @@ def _collect_skipped_intervals(
24162416
select(DagRun)
24172417
.where(
24182418
DagRun.dag_id == serdag.dag_id,
2419-
DagRun.run_type.in_([DagRunType.SCHEDULED]),
2419+
DagRun.run_type == DagRunType.SCHEDULED,
24202420
DagRun.data_interval_end.is_not(None),
24212421
DagRun.data_interval_end <= new_data_interval.start,
24222422
)

0 commit comments

Comments
 (0)