Skip to content

Commit

Permalink
fixup! Query "existing dag runs" one at a time
Browse files Browse the repository at this point in the history
  • Loading branch information
dstandish committed Feb 13, 2024
1 parent c655816 commit 9753973
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion airflow/jobs/scheduler_job_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
from pathlib import Path
from typing import TYPE_CHECKING, Any, Callable, Collection, Iterable, Iterator

from sqlalchemy import and_, delete, func, not_, or_, select, text, update, literal_column, exists
from sqlalchemy import and_, delete, exists, func, literal_column, not_, or_, select, text, update
from sqlalchemy.exc import OperationalError
from sqlalchemy.orm import joinedload, lazyload, load_only, make_transient, selectinload
from sqlalchemy.sql import expression
Expand Down

0 comments on commit 9753973

Please sign in to comment.