Skip to content

Commit 6fe5dda

Browse files
committed
feat(supervisor): 60s dequeue latency bucket to bracket the retry-exhausted error envelope
1 parent 16b693c commit 6fe5dda

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

packages/core/src/v3/runEngineWorker/supervisor/consumerPoolMetrics.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,9 @@ export class ConsumerPoolMetrics {
126126
// long-polls (RUN_ENGINE_DEQUEUE_BLOCKING_TIMEOUT_SECONDS, default 10s),
127127
// parking empty dequeues at ~10s - the 11/12.5/15/20 buckets give the
128128
// quantiles resolution just above that boundary, where the mass sits.
129-
buckets: [0.005, 0.01, 0.025, 0.05, 0.1, 0.25, 0.5, 1, 2, 5, 10, 11, 12.5, 15, 20, 30],
129+
// 60s brackets the worst-case error envelope (5 attempts that each hit
130+
// the ~10s hold, plus backoff); beyond that the connection is hung.
131+
buckets: [0.005, 0.01, 0.025, 0.05, 0.1, 0.25, 0.5, 1, 2, 5, 10, 11, 12.5, 15, 20, 30, 60],
130132
registers: [this.register],
131133
});
132134
}

0 commit comments

Comments
 (0)