diff --git a/packages/core/src/ActiveWorkflows.ts b/packages/core/src/ActiveWorkflows.ts index 4cdcd34594cc4..be23b1312b58f 100644 --- a/packages/core/src/ActiveWorkflows.ts +++ b/packages/core/src/ActiveWorkflows.ts @@ -255,7 +255,16 @@ export class ActiveWorkflows { if (workflowData.triggerResponses) { for (const triggerResponse of workflowData.triggerResponses) { if (triggerResponse.closeFunction) { - await triggerResponse.closeFunction(); + try { + await triggerResponse.closeFunction(); + } catch (error) { + Logger.error( + `There was a problem deactivating trigger of workflow "${id}": "${error.message}"`, + { + workflowId: id, + }, + ); + } } } } @@ -263,7 +272,16 @@ export class ActiveWorkflows { if (workflowData.pollResponses) { for (const pollResponse of workflowData.pollResponses) { if (pollResponse.closeFunction) { - await pollResponse.closeFunction(); + try { + await pollResponse.closeFunction(); + } catch (error) { + Logger.error( + `There was a problem deactivating polling trigger of workflow "${id}": "${error.message}"`, + { + workflowId: id, + }, + ); + } } } }