diff --git a/airflow-core/src/airflow/models/trigger.py b/airflow-core/src/airflow/models/trigger.py index ded88d1d2f899..41cdea470a9a1 100644 --- a/airflow-core/src/airflow/models/trigger.py +++ b/airflow-core/src/airflow/models/trigger.py @@ -324,6 +324,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(