diff --git a/packages/plugins/workflow/src/server/Plugin.ts b/packages/plugins/workflow/src/server/Plugin.ts index c9f867047..a964d9369 100644 --- a/packages/plugins/workflow/src/server/Plugin.ts +++ b/packages/plugins/workflow/src/server/Plugin.ts @@ -152,10 +152,7 @@ export default class WorkflowPlugin extends Plugin { } } - // @ts-ignore - const transaction = options.transaction && !options.transaction.finished - ? options.transaction - : await (workflow.constructor).database.sequelize.transaction(); + const transaction = await (workflow.constructor).database.sequelize.transaction(); const execution = await workflow.createExecution({ context, @@ -189,10 +186,7 @@ export default class WorkflowPlugin extends Plugin { execution.workflow = workflow; - // @ts-ignore - if (transaction && (!options.transaction || options.transaction.finished)) { - await transaction.commit(); - } + await transaction.commit(); setTimeout(() => this.dispatch(execution)); }