1 files changed, 16 insertions, 0 deletions
diff --git a/packages/shared-server/src/queues.ts b/packages/shared-server/src/queues.ts
index 742ebd4d..0748bd92 100644
--- a/packages/shared-server/src/queues.ts
+++ b/packages/shared-server/src/queues.ts
@@ -234,3 +234,19 @@ export async function triggerRuleEngineOnEvent(
     opts,
   );
 }
+
+// Backup worker
+export const zBackupRequestSchema = z.object({
+  userId: z.string(),
+  backupId: z.string().optional(),
+});
+export type ZBackupRequest = z.infer<typeof zBackupRequestSchema>;
+export const BackupQueue = QUEUE_CLIENT.createQueue<ZBackupRequest>(
+  "backup_queue",
+  {
+    defaultJobArgs: {
+      numRetries: 2,
+    },
+    keepFailedJobs: false,
+  },
+);