Skip to content

Commit 86063eb

Browse files
authored
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
1 parent e426528 commit 86063eb

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

airflow-core/src/airflow/models/trigger.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -324,6 +324,11 @@ def assign_unassigned(
324324
capacity -= count
325325

326326
if capacity <= 0:
327+
log.info(
328+
"Triggerer %s has reached the maximum capacity triggers assigned (%d). Not assigning any more triggers",
329+
triggerer_id,
330+
count,
331+
)
327332
return
328333

329334
alive_triggerer_ids = select(Job.id).where(

0 commit comments

Comments
 (0)