chore: no staged changes
This commit is contained in:
@@ -687,11 +687,7 @@ async function processBatch(
|
|||||||
conversationErrorCooldown.delete(conversationKey);
|
conversationErrorCooldown.delete(conversationKey);
|
||||||
shouldScheduleNext = true;
|
shouldScheduleNext = true;
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
consecutiveErrors++;
|
recordConversationBatchFailure(conversationKey);
|
||||||
if (consecutiveErrors >= MAX_CONSECUTIVE_ERRORS) {
|
|
||||||
globalCooldownUntil = Date.now() + 60000;
|
|
||||||
logger.warn("Global circuit breaker triggered due to consecutive errors");
|
|
||||||
}
|
|
||||||
|
|
||||||
// Unhandled exception — route everything to individual fallback.
|
// Unhandled exception — route everything to individual fallback.
|
||||||
logger.warn(
|
logger.warn(
|
||||||
|
|||||||
Reference in New Issue
Block a user