Skip to content

Commit f450cd7

Browse files
authored
Clean up comments in scheduler_job_runner.py
Removed commented-out lines for clarity.
1 parent 3ef4326 commit f450cd7

1 file changed

Lines changed: 1 addition & 9 deletions

File tree

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

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1981,15 +1981,7 @@ def _mark_backfills_complete(self, session: Session = NEW_SESSION) -> None:
19811981
# todo: AIP-78 simplify this function to an update statement
19821982
query = select(Backfill).where(
19831983
Backfill.completed_at.is_(None),
1984-
# Guard: backfill must have at least one
1985-
1986-
1987-
1988-
1989-
1990-
1991-
1992-
association,
1984+
# Guard: backfill must have at least one association,
19931985
# otherwise it is still being set up (see #61375).
19941986
exists(select(BackfillDagRun.id).where(BackfillDagRun.backfill_id == Backfill.id)),
19951987
~exists(

0 commit comments

Comments
 (0)