fix: process empty string

novuhq · Dec 7, 2023 · 5ad6008 · 5ad6008
1 parent ecd4f4e
commit 5ad6008
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/apps/worker/src/config/worker-init.config.ts b/apps/worker/src/config/worker-init.config.ts
@@ -60,14 +60,16 @@ const isQueueEntry = (queueName: string): queueName is JobTopicNameEnum => {
 };
 
 export const workersToProcess =
-  process.env.ACTIVE_WORKERS?.split(',').map((queue) => {
-    const queueName = queue.trim();
-    if (!isQueueEntry(queueName)) {
-      throw new Error(`Invalid queue name ${queueName}`);
-    }
+  process.env.ACTIVE_WORKERS?.split(',')
+    .filter((i) => !!i)
+    .map((queue) => {
+      const queueName = queue.trim();
+      if (!isQueueEntry(queueName)) {
+        throw new Error(`Invalid queue name ${queueName}`);
+      }
 
-    return queueName;
-  }) || [];
+      return queueName;
+    }) || [];
 
 const WORKER_DEPENDENCIES: JobTopicNameEnum[] = workersToProcess.reduce((history, worker) => {
   const workerDependencies: JobTopicNameEnum[] = WORKER_MAPPING[worker]?.queueDependencies || [];