From d027bae31145876f79d7dc687cbe6030f8770a09 Mon Sep 17 00:00:00 2001 From: Jackson Harper Date: Fri, 1 Nov 2024 23:46:57 +0800 Subject: [PATCH 1/2] Send exports to the export queue --- packages/api/src/utils/createTask.ts | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/packages/api/src/utils/createTask.ts b/packages/api/src/utils/createTask.ts index 72054ac0d..299551395 100644 --- 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 } From 0b6e5d14389541b6454ea13a88052fece1942d04 Mon Sep 17 00:00:00 2001 From: Jackson Harper Date: Sat, 2 Nov 2024 00:23:51 +0800 Subject: [PATCH 2/2] Add export queue to the queue admin --- pkg/bull-queue-admin/index.js | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/bull-queue-admin/index.js b/pkg/bull-queue-admin/index.js index 49b275ec3..3363df6c4 100644 --- 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,