From 8083002e046313ae68930144e67b7bd3bf4d8ebb Mon Sep 17 00:00:00 2001
From: Bechamelle <43265791+Bechamelle@users.noreply.github.com>
Date: Fri, 19 Sep 2025 15:59:47 +0200
Subject: [PATCH] fix(airflow_db_cleanup): removing additional "None" iteration
 upon DagRun cleaning

---
 composer/workflows/airflow_db_cleanup.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/composer/workflows/airflow_db_cleanup.py b/composer/workflows/airflow_db_cleanup.py
index 4eee89ef9ab..0065541e467 100644
--- a/composer/workflows/airflow_db_cleanup.py
+++ b/composer/workflows/airflow_db_cleanup.py
@@ -459,7 +459,7 @@ def cleanup_function(**context):
             dags = session.query(airflow_db_model.dag_id).distinct()
             session.commit()
 
-            list_dags = [str(list(dag)[0]) for dag in dags] + [None]
+            list_dags = [str(list(dag)[0]) for dag in dags]
             for dag_id in list_dags:
                 query = build_query(
                     session=session,