Skip to content

Commit 6f7bcc5

Browse files
committed
fix an existing run queue cooloff issue that was surfaced by this ck work to reset the cooloff state when a queue is successfully dequeued from
1 parent b20477d commit 6f7bcc5

File tree

1 file changed

+5
-0
lines changed
  • internal-packages/run-engine/src/run-queue

1 file changed

+5
-0
lines changed

internal-packages/run-engine/src/run-queue/index.ts

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1578,6 +1578,11 @@ export class RunQueue {
15781578
continue;
15791579
}
15801580

1581+
if (messages.length > 0) {
1582+
// Reset cooloff state on successful dequeue
1583+
this._queueCooloffStates.delete(queue);
1584+
}
1585+
15811586
if (messages.length === 0) {
15821587
if (cooloffState._tag === "normal") {
15831588
const cooloffCountThreshold = Math.max(

0 commit comments

Comments
 (0)