Merge pull request #4478 from omnivore-app/jacksonh/export-queue

Send exports to the export queue
omnivore-app · Nov 1, 2024 · fc38248 · fc38248
2 parents 0bc1135 + 0b6e5d1
commit fc38248
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/packages/api/src/utils/createTask.ts b/packages/api/src/utils/createTask.ts
@@ -1075,8 +1075,7 @@ export const enqueueExpireFoldersJob = async () => {
 }
 
 export const queueExportJob = async (userId: string, exportId: string) => {
-  const queue = await getQueue()
-  // const queue = await getQueue(EXPORT_QUEUE_NAME)
+  const queue = await getQueue(EXPORT_QUEUE_NAME)
   if (!queue) {
     return undefined
   }

diff --git a/pkg/bull-queue-admin/index.js b/pkg/bull-queue-admin/index.js
@@ -62,6 +62,9 @@ const run = async () => {
   const backendQueue = new Queue('omnivore-backend-queue', {
     connection: connection,
   })
+  const exportQueue = new Queue('omnivore-export-queue', {
+    connection: connection,
+  })
   const contentFetchQueue = new Queue('omnivore-content-fetch-queue', {
     connection: connection,
   })
@@ -72,6 +75,7 @@ const run = async () => {
   createBullBoard({
     queues: [
       new BullMQAdapter(backendQueue),
+      new BullMQAdapter(exportQueue),
       new BullMQAdapter(contentFetchQueue),
     ],
     serverAdapter,