This is an automated email from the ASF dual-hosted git repository.
jedcunningham pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 9e2658ea88 Remove commented out code (#24685)
9e2658ea88 is described below
commit 9e2658ea8850b0bacba8a3fe82c457dbeb48d591
Author: Andrey Anshin <andrey.ans...@taragol.is>
AuthorDate: Tue Jun 28 08:04:19 2022 +0400
Remove commented out code (#24685)
---
airflow/dag_processing/processor.py | 15 ---------------
1 file changed, 15 deletions(-)
diff --git a/airflow/dag_processing/processor.py
b/airflow/dag_processing/processor.py
index cc759f7854..c11243e76e 100644
--- a/airflow/dag_processing/processor.py
+++ b/airflow/dag_processing/processor.py
@@ -733,18 +733,3 @@ class DagFileProcessor(LoggingMixin):
self.log.exception("Error logging DAG warnings.")
return len(dagbag.dags), len(dagbag.import_errors)
-
-
-#
-# from airflow import settings
-#
-# session = settings.Session()
-# from airflow.models.dagwarning import DagWarning
-# stored_warnings = set(
-#
session.query(DagWarning).filter(DagWarning.dag_id.in_(('resource',))).all()
-# )
-# dag_ids = session.query(DagModel).filter(DagModel.is_active == false()).all()
-#
session.query(cls).filter(cls.dag_id.in_(dag_ids)).delete(synchronize_session=False)
-#
-# for warning_to_delete in stored_warnings:
-# session.delete(warning_to_delete)
