This is an automated email from the ASF dual-hosted git repository. rahulvats pushed a commit to branch fix/asset-watcher-null-trigger-guard in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 5fcc98f2f9e897eea6a86349658681770b7ffb81 Author: vatsrahul1001 <[email protected]> AuthorDate: Fri Apr 3 12:14:08 2026 +0530 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 1d60c32020f..96f3c89f862 100644 --- a/airflow-core/src/airflow/dag_processing/collection.py +++ b/airflow-core/src/airflow/dag_processing/collection.py @@ -1101,7 +1101,8 @@ class AssetModelOperation(NamedTuple): 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 ]
