diff --git a/services/discord-gateway/src/modules/ai-moderation/aiAnalyzer.ts b/services/discord-gateway/src/modules/ai-moderation/aiAnalyzer.ts index 0ba4c8e..b1ffdb6 100644 --- a/services/discord-gateway/src/modules/ai-moderation/aiAnalyzer.ts +++ b/services/discord-gateway/src/modules/ai-moderation/aiAnalyzer.ts @@ -616,13 +616,7 @@ async function processBatch( } if (!result.ok) { - consecutiveErrors++; - if (consecutiveErrors >= MAX_CONSECUTIVE_ERRORS) { - globalCooldownUntil = Date.now() + 60000; - logger.warn( - "Global circuit breaker triggered due to consecutive errors", - ); - } + recordConversationBatchFailure(conversationKey); // Batch failed entirely — fall back all messages to individual queue // so no message is permanently lost behind a cooldown.