prehistoric-systems/omnivore
1
0
Fork 0
mirror of https://github.com/omnivore-app/omnivore.git synced 2026-03-11 08:54:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Wait until backend queue is ready before putting jobs into it

Browse source
This commit is contained in:
Jackson Harper 2024-01-22 11:31:46 +08:00
parent f7b17cb93f
commit db8284dc0b
2 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
packages/api/src/jobs/rss/refreshAllFeeds.ts
View file

@ -106,7 +106,7 @@ const updateSubscriptionGroup = async (
}
export const queueRSSRefreshAllFeedsJob = async () => {
const queue = getBackendQueue()
const queue = await getBackendQueue()
if (!queue) {
return false
}
@ -126,7 +126,7 @@ export const queueRSSRefreshFeedJob = async (
payload: any,
options = { priority: 'high' as QueuePriority }
): Promise<Job | undefined> => {
const queue = getBackendQueue()
const queue = await getBackendQueue()
if (!queue) {
return undefined
}

4
packages/api/src/queue-processor.ts
View file

@ -16,8 +16,9 @@ import { CustomTypeOrmLogger } from './utils/logger'
export const QUEUE_NAME = 'omnivore-backend-queue'
let backendQueue: Queue | undefined
export const getBackendQueue = (): Queue | undefined => {
export const getBackendQueue = async (): Promise<Queue | undefined> => {
if (backendQueue) {
await backendQueue.waitUntilReady()
return backendQueue
}
if (!redisDataSource.workerRedisClient) {
@ -26,6 +27,7 @@ export const getBackendQueue = (): Queue | undefined => {
backendQueue = new Queue(QUEUE_NAME, {
connection: redisDataSource.workerRedisClient,
})
await backendQueue.waitUntilReady()
return backendQueue
}