This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new 90b5ec0181d [v3-0-test] Log when triggerer has reached the maximum
trigger capacity (#54536) (#54549)
90b5ec0181d is described below
commit 90b5ec0181d0a4e958b373e9970b70f3ef0946ba
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Aug 16 22:38:35 2025 +0200
[v3-0-test] Log when triggerer has reached the maximum trigger capacity
(#54536) (#54549)
Might help to know that a triggerer has reached the maximum number
of triggers it can run
(cherry picked from commit 86063eb5f38d8332048ca542351b71b77ec42ac0)
Co-authored-by: Ephraim Anierobi <[email protected]>
---
airflow-core/src/airflow/models/trigger.py | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/airflow-core/src/airflow/models/trigger.py
b/airflow-core/src/airflow/models/trigger.py
index 94d8360edf9..e2e89a3b8d6 100644
--- a/airflow-core/src/airflow/models/trigger.py
+++ b/airflow-core/src/airflow/models/trigger.py
@@ -316,6 +316,11 @@ class Trigger(Base):
capacity -= count
if capacity <= 0:
+ log.info(
+ "Triggerer %s has reached the maximum capacity triggers
assigned (%d). Not assigning any more triggers",
+ triggerer_id,
+ count,
+ )
return
alive_triggerer_ids = select(Job.id).where(
