Skip to content

Commit 0ab9566

Browse files
authored
Fix some dag_runs removed unintentionally (#13576)
* Fix last removal of dag_run with None as dag_id * Fix quotes
1 parent a8ec9f8 commit 0ab9566

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

composer/workflows/airflow_db_cleanup.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -360,7 +360,8 @@ def build_query(
360360

361361
logging.info("INITIAL QUERY : " + str(query))
362362

363-
if dag_id:
363+
if hasattr(airflow_db_model, 'dag_id'):
364+
logging.info("Filtering by dag_id: " + str(dag_id))
364365
query = query.filter(airflow_db_model.dag_id == dag_id)
365366

366367
if airflow_db_model == DagRun:

0 commit comments

Comments
 (0)