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(