From f0bffa6a80cfb5b1d3d96a250f4c0571dfb8ab11 Mon Sep 17 00:00:00 2001 From: Ephraim Anierobi Date: Fri, 15 Aug 2025 13:52:28 +0100 Subject: [PATCH] [v3-0-test] Log when triggerer has reached the maximum trigger capacity (#54536) 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 --- 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 94d8360edf9e7..e2e89a3b8d6bc 100644 --- a/airflow-core/src/airflow/models/trigger.py +++ b/airflow-core/src/airflow/models/trigger.py @@ -316,6 +316,11 @@ def assign_unassigned( 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(