Skip to content

Commit 16eaa5e

Browse files
authored
Remove extra bracket in query (apache#45735)
This was causing error in dag processor manager logging
1 parent 6cde25f commit 16eaa5e

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

airflow/dag_processing/manager.py

+3-5
Original file line numberDiff line numberDiff line change
@@ -761,11 +761,9 @@ def clear_nonexistent_import_errors(self, session=NEW_SESSION):
761761

762762
if self._file_paths:
763763
query = query.where(
764-
(
765-
tuple_(ParseImportError.filename, ParseImportError.bundle_name).notin_(
766-
[(f.path, f.bundle_name) for f in self._file_paths]
767-
),
768-
)
764+
tuple_(ParseImportError.filename, ParseImportError.bundle_name).notin_(
765+
[(f.path, f.bundle_name) for f in self._file_paths]
766+
),
769767
)
770768

771769
session.execute(query.execution_options(synchronize_session="fetch"))

0 commit comments

Comments
 (0)