From 5fcc98f2f9e897eea6a86349658681770b7ffb81 Mon Sep 17 00:00:00 2001 From: vatsrahul1001 Date: Fri, 3 Apr 2026 12:14:08 +0530 Subject: [PATCH] Guard against null trigger in asset watcher cleanup --- airflow-core/src/airflow/dag_processing/collection.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/airflow-core/src/airflow/dag_processing/collection.py b/airflow-core/src/airflow/dag_processing/collection.py index 1d60c32020fc3..96f3c89f8623a 100644 --- a/airflow-core/src/airflow/dag_processing/collection.py +++ b/airflow-core/src/airflow/dag_processing/collection.py @@ -1101,7 +1101,8 @@ def add_asset_trigger_references( asset_model.watchers = [ watcher for watcher in asset_model.watchers - if BaseEventTrigger.hash(watcher.trigger.classpath, watcher.trigger.kwargs) + if watcher.trigger is not None + and BaseEventTrigger.hash(watcher.trigger.classpath, watcher.trigger.kwargs) not in trigger_hashes ]