File tree Expand file tree Collapse file tree 1 file changed +8
-7
lines changed
apps/sim/worker/processors Expand file tree Collapse file tree 1 file changed +8
-7
lines changed Original file line number Diff line number Diff line change @@ -10,12 +10,13 @@ export async function processResume(job: Job<BullMQJobData<ResumeExecutionPayloa
1010 const { payload } = job . data
1111 const isFinalAttempt = job . attemptsMade + 1 >= ( job . opts . attempts ?? 1 )
1212
13- return runDispatchedJob ( job , isFinalAttempt , async ( ) => {
14- logger . info ( 'Processing resume execution job' , {
15- jobId : job . id ,
16- resumeExecutionId : payload . resumeExecutionId ,
17- workflowId : payload . workflowId ,
18- } )
19- return executeResumeJob ( payload )
13+ logger . info ( 'Processing resume execution job' , {
14+ jobId : job . id ,
15+ resumeExecutionId : payload . resumeExecutionId ,
16+ workflowId : payload . workflowId ,
17+ } )
18+
19+ return runDispatchedJob ( job . data . metadata , ( ) => executeResumeJob ( payload ) , {
20+ isFinalAttempt,
2021 } )
2122}
You can’t perform that action at this time.
0 commit comments