Better trigger visibility for watchers

[dstandish]

Body

In triggerer stdout probably we should distinguish between triggers running and watchers running.

I know it's not really a "watcher" that's running, but rather a trigger that is running for a watcher. Maybe we should change that.

In any case, rather than showing

1 triggers currently running

I tihnk it would be better to show

1 watcher running
0 triggers running

E.g. right now as shown in image below there's nothing that indicates whether it's a "normal" trigger or a watcher trigger

Committer

• I acknowledge that I am a maintainer/committer of the Apache Airflow project.

[dstandish]

cc @vincbeck @Lee-W @jroachgolf84 @cmarteepants

[tirkarthi]

An additional key is_watcher could be included in the self.triggers that is true if the trigger_instance is an instance of BaseEventTrigger. Then during the logging of count group by is_watcher as True and False to get watchers and triggers to log something below or as separate lines.

2025-09-06 06:54:24.174950 [info     ] 3 triggers and 1 watchers currently running [airflow.jobs.triggerer_job_runner]

airflow/airflow-core/src/airflow/jobs/triggerer_job_runner.py

Lines 963 to 969 in 230da3e

	self.triggers[trigger_id] = {
	"task": asyncio.create_task(
	self.run_trigger(trigger_id, trigger_instance), name=trigger_name
	),
	"name": trigger_name,
	"events": 0,
	}

diff --git a/airflow-core/src/airflow/jobs/triggerer_job_runner.py b/airflow-core/src/airflow/jobs/triggerer_job_runner.py
index 63deea50f4..fd3d4d0fa8 100644
--- a/airflow-core/src/airflow/jobs/triggerer_job_runner.py
+++ b/airflow-core/src/airflow/jobs/triggerer_job_runner.py
@@ -878,8 +878,9 @@ class TriggerRunner:
                 await asyncio.sleep(1)
                 # Every minute, log status
                 if (now := time.monotonic()) - last_status >= 60:
-                    count = len(self.triggers)
-                    self.log.info("%i triggers currently running", count)
+                    watchers = len([trigger for trigger in self.triggers.values() if trigger["is_watcher"]])
+                    triggers = len(self.triggers) - watchers
+                    self.log.info("%i triggers and %i watchers currently running", triggers, watchers)
                     last_status = now
 
         except Exception:
@@ -964,6 +965,7 @@ class TriggerRunner:
                 "task": asyncio.create_task(
                     self.run_trigger(trigger_id, trigger_instance), name=trigger_name
                 ),
+                "is_watcher": isinstance(trigger_instance, events.BaseEventTrigger),
                 "name": trigger_name,
                 "events": 0,
             }

[vincbeck]

Indeed, it could be a good small improvement for better visibility