chore: no staged changes
This commit is contained in:
@@ -616,13 +616,7 @@ async function processBatch(
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (!result.ok) {
|
if (!result.ok) {
|
||||||
consecutiveErrors++;
|
recordConversationBatchFailure(conversationKey);
|
||||||
if (consecutiveErrors >= MAX_CONSECUTIVE_ERRORS) {
|
|
||||||
globalCooldownUntil = Date.now() + 60000;
|
|
||||||
logger.warn(
|
|
||||||
"Global circuit breaker triggered due to consecutive errors",
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Batch failed entirely — fall back all messages to individual queue
|
// Batch failed entirely — fall back all messages to individual queue
|
||||||
// so no message is permanently lost behind a cooldown.
|
// so no message is permanently lost behind a cooldown.
|
||||||
|
|||||||
Reference in New Issue
Block a user