Skip to content

Commit 90b5ec0

Browse files
[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 86063eb) Co-authored-by: Ephraim Anierobi <[email protected]>
1 parent e797f83 commit 90b5ec0

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
@@ -316,6 +316,11 @@ def assign_unassigned(
316316
capacity -= count
317317

318318
if capacity <= 0:
319+
log.info(
320+
"Triggerer %s has reached the maximum capacity triggers assigned (%d). Not assigning any more triggers",
321+
triggerer_id,
322+
count,
323+
)
319324
return
320325

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

0 commit comments

Comments
 (0)