diff --git a/packages/backend/src/workers/action.ts b/packages/backend/src/workers/action.ts index dcc79cf5..c06833d3 100644 --- a/packages/backend/src/workers/action.ts +++ b/packages/backend/src/workers/action.ts @@ -26,6 +26,8 @@ export const worker = new Worker( const { stepId, flowId, executionId, computedParameters, executionStep } = await processAction(job.data as JobData); + if (executionStep.isFailed) return; + const step = await Step.query().findById(stepId).throwIfNotFound(); const nextStep = await step.getNextStep();