Fix client imports
This commit is contained in:
@ -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
|
||||
|
||||
@ -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'
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user