From ba3816fb40dc9c4d18e9db594f5331d1fd1093b8 Mon Sep 17 00:00:00 2001
From: Dominic Ferrando <dominicf2001@gmail.com>
Date: Sat, 18 Jul 2026 01:18:28 -0400
Subject: [PATCH] Add short delay for already claimed event retryc

---
 apps/api/src/services/event-queue.ts | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/apps/api/src/services/event-queue.ts b/apps/api/src/services/event-queue.ts
index 5b71e3f..8c8ac28 100644
--- a/apps/api/src/services/event-queue.ts
+++ b/apps/api/src/services/event-queue.ts
@@ -46,6 +46,7 @@ function exponentialDelay(initialDelay: number, tries: number, cap: number = Inf
 }
 
 export class EventQueue<G extends string, T extends Record<string, EventTypeOptions<any, any>>> {
+    private static readonly DEQUEUE_ALREADY_CLAIMED_SKIP_DELAY_MS = 250;
     private static readonly DEQUEUE_RETRY_DELAY_MS = secToMs(10);
     private static readonly DEQUEUE_RETRY_LIMIT = 3;
     private static readonly RATE_LIMIT_RETRY_LIMIT = 15;
@@ -78,6 +79,7 @@ export class EventQueue<G extends string, T extends Record<string, EventTypeOpti
             catch (err) {
                 if (err instanceof AlreadyClaimedEventError) {
                     log.warn("event processing already claimed by another worker, skipping");
+                    await sleep(EventQueue.DEQUEUE_ALREADY_CLAIMED_SKIP_DELAY_MS);
                     continue;
                 }
                 if (err instanceof ConcurrencyLimitReachedError) {