Add on_skipped_intervals_callback for catchup=False DAGs - #68359

Open

Tegh25 wants to merge 23 commits into

apache:mainfrom

Tegh25:feature/add_dag_catchup_skip_callback

Commits on Aug 19, 2026

Add on_skipped_intervals_callback for catchup=False Dags
Tegh25
committed
1d1d409
Add unit tests for skipped intervals callback and listener
Tegh25
committed
d7fe1e1
Add docs and newsfragment for skipped intervals callback and listener
Tegh25
committed
b163117
Fix callback types table, add skipped intervals callback to ignored keys
Tegh25
committed
abbb8fc
Apply linting fixes after rebase
Tegh25
committed
1303188
Use gap summary for skipped intervals callback and listener
Tegh25
committed
a5c4af8
Type on_skipped_intervals_callback with SkippedIntervalsCallbackContext, update schema versioning
Tegh25
committed
9bdd20e
Update scheduler_job_runner.py comment with correct Dag capitalization

Tegh25
and
ferruzzi
committed
2ba772a
Update DagSkippedIntervalsCallbackRequest docstring, replace .in_() with ==
Tegh25
committed
5a78b5d
Fix linting errors after rebase and regenerate schema
Tegh25
committed
67c5f83
Remove skipped_interval_count field from callback/listener payload
Tegh25
committed
65cf130
Restore supervisor schema version 2026-06-16 for backward compatibility
Tegh25
committed
e1faf94
Document SkippedIntervalsCallbackContext for Sphinx inventory
Tegh25
committed
6162cac
Skipped intervals listener hook moved outside of retry_db_transaction
Tegh25
committed
c558c2d
Fix: version migration iterates through callback dict to remove new skipped interval fields
Tegh25
committed
619134d
Update task-sdk schema.json and ts-sdk supervisor.ts as per hooks
Tegh25
committed
3e6e4e9
Update schema version references in Go sdk
Tegh25
committed
fcf2cfa
Avoid false skipped-interval callbacks for consecutive trigger timetable runs
Tegh25
committed
30985bd
Remove stray blank line right after _execute_dag_skipped_intervals_callback signature
Tegh25
committed
9511066
Ruff formatting for callback requests imports on test scheduler job
Tegh25
committed
beeeed1
Document callback behaviour when there are no previous Dag runs
Tegh25
committed
f321060
Narrow log_extra scope for skipped intervals callback in request
Tegh25
committed
fbed9e5
Align skipped-interval callback metrics and simplify guard logic
Tegh25
committed
20546cd

Navigation Menu

Uh oh!

Add on_skipped_intervals_callback for catchup=False DAGs - #68359

Add on_skipped_intervals_callback for catchup=False DAGs#68359
Tegh25 wants to merge 23 commits into
apache:mainfrom
Tegh25:feature/add_dag_catchup_skip_callback

Commits on Aug 19, 2026

Add on_skipped_intervals_callback for catchup=False Dags

Add unit tests for skipped intervals callback and listener

Add docs and newsfragment for skipped intervals callback and listener

Fix callback types table, add skipped intervals callback to ignored keys

Apply linting fixes after rebase

Use gap summary for skipped intervals callback and listener

Type on_skipped_intervals_callback with SkippedIntervalsCallbackContext, update schema versioning

Update scheduler_job_runner.py comment with correct Dag capitalization

Update DagSkippedIntervalsCallbackRequest docstring, replace .in_() with ==

Fix linting errors after rebase and regenerate schema

Remove skipped_interval_count field from callback/listener payload

Restore supervisor schema version 2026-06-16 for backward compatibility

Document SkippedIntervalsCallbackContext for Sphinx inventory

Skipped intervals listener hook moved outside of retry_db_transaction

Fix: version migration iterates through callback dict to remove new skipped interval fields

Update task-sdk schema.json and ts-sdk supervisor.ts as per hooks

Update schema version references in Go sdk

Avoid false skipped-interval callbacks for consecutive trigger timetable runs

Remove stray blank line right after _execute_dag_skipped_intervals_callback signature

Ruff formatting for callback requests imports on test scheduler job

Document callback behaviour when there are no previous Dag runs

Narrow log_extra scope for skipped intervals callback in request

Align skipped-interval callback metrics and simplify guard logic