diff --git a/streaming/index.js b/streaming/index.js index 9e6d69d4eb..3937d0ec01 100644 --- a/streaming/index.js +++ b/streaming/index.js @@ -42,7 +42,9 @@ const createRedisClient = async (config) => { // so apparently ioredis doesn't handle relative paths let client; - if (parsed.host === null && parsed.path[0] === '.') { + if (!redisUrl) { + client = new Redis(redisParams); + } else if (parsed.host === null && parsed.path[0] === '.') { redisParams.path = parsed.path; client = new Redis(redisParams); } else if (parsed.host === '.' || parsed.protocol === 'unix:' && parsed.host !== '') {