Skip to content

Commit

Permalink
Temporarily disable deactivating deleted DAGs
Browse files Browse the repository at this point in the history
There is a bug that results in all DAGs being deleted constantly, which
isn't very helpful :)
  • Loading branch information
jedcunningham committed Jan 31, 2025
1 parent b9721d6 commit d7d1827
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion airflow/dag_processing/manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -498,7 +498,8 @@ def _refresh_dag_bundles(self):
new_file_paths.extend(found_file_infos)
self.set_file_paths(new_file_paths)

self.deactivate_deleted_dags(active_files=found_file_infos)
# TODO AIP-66: this just removes all DAGs
# self.deactivate_deleted_dags(active_files=found_file_infos)
self.clear_nonexistent_import_errors()

self._bundle_versions[bundle.name] = bundle.get_current_version()
Expand Down

0 comments on commit d7d1827

Please sign in to comment.