feat(web): add new indices to request and improve queue retries

tryabby · Jun 20, 2024 · c42a6fe · c42a6fe
1 parent fe05b9e
commit c42a6fe
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/apps/web/prisma/schema.prisma b/apps/web/prisma/schema.prisma
@@ -307,4 +307,6 @@ model ApiRequest {
   project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade)
 
   @@index([projectId])
+  @@index([createdAt])
+  @@index([type])
 }
diff --git a/apps/web/src/server/queue/queues.ts b/apps/web/src/server/queue/queues.ts
@@ -16,11 +16,25 @@ export const getQueueingRedisConnection = () =>
 
 export const eventQueue = new Queue<EventJobPayload>(QUEUE_NAMES.events, {
   connection: getQueueingRedisConnection(),
+  defaultJobOptions: {
+    attempts: 3,
+    backoff: {
+      type: "exponential",
+      delay: 1000,
+    },
+  },
 });
 
 export const afterDataRequestQueue = new Queue<AfterRequestJobPayload>(
   QUEUE_NAMES.afterDataRequestQueue,
   {
     connection: getQueueingRedisConnection(),
+    defaultJobOptions: {
+      attempts: 3,
+      backoff: {
+        type: "exponential",
+        delay: 1000,
+      },
+    },
   }
 );