You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by je...@apache.org on 2022/06/28 04:04:33 UTC

[airflow] branch main updated: Remove commented out code (#24685)

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 <An...@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)