(airflow) branch fix/asset-watcher-null-trigger-guard created (now 5fcc98f2f9e)

[ra...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rahulvats pushed a change to branch fix/asset-watcher-null-trigger-guard
in repository https://gitbox.apache.org/repos/asf/airflow.git


      at 5fcc98f2f9e Guard against null trigger in asset watcher cleanup

This branch includes the following new commits:

     new 5fcc98f2f9e Guard against null trigger in asset watcher cleanup

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(airflow) 01/01: Guard against null trigger in asset watcher cleanup

[ra...@apache.org]

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 <ra...@gmail.com>
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
                 ]