test: add types on processor params (#2885)

taskforcesh · Nov 12, 2024 · fa51711 · fa51711
1 parent b70dbdf
commit fa51711
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tests/test_flow.ts b/tests/test_flow.ts
@@ -990,7 +990,7 @@ describe('flows', () => {
 
       const worker = new Worker(
         queueName,
-        async (job, token) => {
+        async (job: Job, token?: string) => {
           let step = job.data.step;
           while (step !== Step.Finish) {
             switch (step) {
@@ -1013,7 +1013,7 @@ describe('flows', () => {
                   ],
                   opts: {
                     parent: {
-                      id: job.id,
+                      id: job.id!,
                       queue: job.queueQualifiedName,
                     },
                   },
@@ -1032,7 +1032,7 @@ describe('flows', () => {
                 break;
               }
               case Step.Third: {
-                const shouldWait = await job.moveToWaitingChildren(token);
+                const shouldWait = await job.moveToWaitingChildren(token!);
                 if (!shouldWait) {
                   await job.updateData({
                     step: Step.Finish,