diff --git a/packages/api/src/queue-processor.ts b/packages/api/src/queue-processor.ts index c59eb9d18..8e1ec5d2f 100644 --- a/packages/api/src/queue-processor.ts +++ b/packages/api/src/queue-processor.ts @@ -56,10 +56,8 @@ const main = async () => { await appDataSource.initialize() await redisDataSource.initialize() - const redisClient = redisDataSource.redisClient const ioRedisClient = redisDataSource.ioRedisClient - - if (!redisClient || !ioRedisClient) { + if (!ioRedisClient) { throw '[queue-processor] error redis is not initialized' } @@ -71,7 +69,7 @@ const main = async () => { return await refreshAllFeeds(appDataSource, ioRedisClient) } case 'refresh-feed': { - return await refreshFeed(redisClient, job.data) + return await refreshFeed(ioRedisClient, job.data) } } return true diff --git a/packages/api/src/utils/helpers.ts b/packages/api/src/utils/helpers.ts index 2397738fd..0763f4a74 100644 --- a/packages/api/src/utils/helpers.ts +++ b/packages/api/src/utils/helpers.ts @@ -416,8 +416,7 @@ export const setRecentlySavedItemInRedis = async ( url: string ) => { // save the url in redis for 26 hours so rss-feeder won't try to re-save it - const client = redisDataSource.redisClient - if (!client) { + if (!redisClient) { console.info( 'not setting recently saved item because redis is not configured' )