diff --git a/ving/jobs/queue.mjs b/ving/jobs/queue.mjs index f45d57c5..9f250fcb 100644 --- a/ving/jobs/queue.mjs +++ b/ving/jobs/queue.mjs @@ -14,7 +14,7 @@ import { jobHandlers } from '#ving/jobs/map.mjs'; export const getQueue = (options = {}) => { const params = { connection: useRedis() }; if (params.connection.isCluster) { - params.prefix = 'vingjobs'; + params.prefix = '{vingjobs}'; } const queue = new Queue(options?.queueName || 'jobs', params); return queue;