ashb commented on code in PR #22917:
URL: https://github.com/apache/airflow/pull/22917#discussion_r848476163
##
airflow/models/serialized_dag.py:
##
@@ -220,6 +220,36 @@ def remove_dag(cls, dag_id: str, session: Session = None):
"""
session.execute(cls.__table_
ashb commented on code in PR #22917:
URL: https://github.com/apache/airflow/pull/22917#discussion_r848447538
##
airflow/models/serialized_dag.py:
##
@@ -220,6 +220,36 @@ def remove_dag(cls, dag_id: str, session: Session = None):
"""
session.execute(cls.__table_
ashb commented on code in PR #22917:
URL: https://github.com/apache/airflow/pull/22917#discussion_r847739746
##
airflow/models/serialized_dag.py:
##
@@ -220,6 +220,36 @@ def remove_dag(cls, dag_id: str, session: Session = None):
"""
session.execute(cls.__table_
ashb commented on code in PR #22917:
URL: https://github.com/apache/airflow/pull/22917#discussion_r847739271
##
airflow/models/serialized_dag.py:
##
@@ -220,6 +220,36 @@ def remove_dag(cls, dag_id: str, session: Session = None):
"""
session.execute(cls.__table_