th: fix streaming

1 year ago · d22e3b86f2
parent 150feaf9b7
commit d22e3b86f2
1 changed files with 3 additions and 1 deletions
--- 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 !== '') {