Skip to content

Commit 2f5ac59

Browse files
committed
fix: use app's createRedisClient
1 parent 43cdc1c commit 2f5ac59

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

packages/backend/src/workers/helpers/buffer-scheduled-jobs.ts

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,8 @@
1-
import IORedis from 'ioredis'
2-
31
import {
42
SCHEDULER_DEFAULT_INTERVAL_IN_MS,
53
SCHEDULER_MAX_DELAY_IN_MS,
64
} from '@/apps/scheduler/common/constants'
5+
import { createRedisClient } from '@/config/redis'
76
import {
87
REMOVE_AFTER_7_DAYS_OR_50_JOBS,
98
REMOVE_AFTER_30_DAYS,
@@ -12,13 +11,19 @@ import Flow from '@/models/flow'
1211
import triggerQueue from '@/queues/trigger'
1312
import { processFlow } from '@/services/flow'
1413

15-
const redis = new IORedis()
14+
const redisClient = createRedisClient()
1615

1716
export async function acquireCoordinationLock(
1817
timestamp: string,
1918
): Promise<boolean> {
2019
const key = `buffer-lock:${timestamp}`
21-
const lock = await redis.set(key, '1', 'PX', SCHEDULER_MAX_DELAY_IN_MS, 'NX')
20+
const lock = await redisClient.set(
21+
key,
22+
'1',
23+
'PX',
24+
SCHEDULER_MAX_DELAY_IN_MS,
25+
'NX',
26+
)
2227
return lock === 'OK'
2328
}
2429

0 commit comments

Comments
 (0)