Skip to content

Commit efd3111

Browse files
committed
style(dag): normalize line endings in DDRQ serialized-DAG guard block
1 parent ca2d9ba commit efd3111

1 file changed

Lines changed: 10 additions & 10 deletions

File tree

airflow/models/dag.py

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -4100,16 +4100,16 @@ def dag_ready(dag_id: str, cond: BaseDataset, statuses: dict) -> bool | None:
41004100
select(SerializedDagModel).where(SerializedDagModel.dag_id.in_(dag_statuses.keys()))
41014101
).all()
41024102
ser_dag_ids = {s.dag_id for s in ser_dags}
4103-
missing_from_serialized = set(by_dag.keys()) - ser_dag_ids
4104-
if missing_from_serialized:
4105-
log.debug(
4106-
"Dags have queued dataset events (DDRQs), but are not found in the serialized_dag table."
4107-
" — skipping Dag run creation: %s",
4108-
sorted(missing_from_serialized),
4109-
)
4110-
for dag_id in missing_from_serialized:
4111-
del by_dag[dag_id]
4112-
del dag_statuses[dag_id]
4103+
missing_from_serialized = set(by_dag.keys()) - ser_dag_ids
4104+
if missing_from_serialized:
4105+
log.debug(
4106+
"Dags have queued dataset events (DDRQs), but are not found in the serialized_dag table."
4107+
" — skipping Dag run creation: %s",
4108+
sorted(missing_from_serialized),
4109+
)
4110+
for dag_id in missing_from_serialized:
4111+
del by_dag[dag_id]
4112+
del dag_statuses[dag_id]
41134113
for ser_dag in ser_dags:
41144114
dag_id = ser_dag.dag_id
41154115
statuses = dag_statuses[dag_id]

0 commit comments

Comments
 (0)