refactor(queue): return the original error instance

weyoss · May 11, 2024 · 14228ec · 14228ec
1 parent 45b1dbd
commit 14228ec
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/lib/queue/_/_parse-queue-extended-params.ts b/src/lib/queue/_/_parse-queue-extended-params.ts
@@ -31,17 +31,15 @@ export function _parseQueueExtendedParams(
 ): IQueueParsedParams | QueueInvalidQueueParameterError {
   if (typeof args === 'string') {
     const queueParams = _parseQueueParams(args);
-    if (queueParams instanceof Error)
-      return new QueueInvalidQueueParameterError();
+    if (queueParams instanceof Error) return queueParams;
     return {
       queueParams,
       groupId: null,
     };
   }
   if (isQueueParams(args)) {
     const queueParams = _parseQueueParams(args);
-    if (queueParams instanceof Error)
-      return new QueueInvalidQueueParameterError();
+    if (queueParams instanceof Error) return queueParams;
     return {
       queueParams,
       groupId: null,