fix(worker): throw error if connection is missing

taskforcesh · Dec 21, 2023 · 6491a18 · 6491a18
1 parent f729be4
commit 6491a18
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/classes/worker.ts b/src/classes/worker.ts
@@ -195,7 +195,7 @@ export class Worker<
   constructor(
     name: string,
     processor?: string | URL | null | Processor<DataType, ResultType, NameType>,
-    opts: WorkerOptions = {},
+    opts?: WorkerOptions,
     Connection?: typeof RedisConnection,
   ) {
     super(
@@ -207,6 +207,10 @@ export class Worker<
       Connection,
     );
 
+    if (!opts || !opts.connection) {
+      throw new Error('Worker requires a connection');
+    }
+
     this.opts = {
       drainDelay: 5,
       concurrency: 1,