tirkarthi commented on issue #55314: URL: https://github.com/apache/airflow/issues/55314#issuecomment-3261424030
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] ``` https://github.com/apache/airflow/blob/230da3e399c26699daad9fd95a413a844f7cb13f/airflow-core/src/airflow/jobs/triggerer_job_runner.py#L963-L969 ```diff 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, } ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
