admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-22 12:19:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: Fix workflow deactivating bug

Browse Source 
Fix a bug which crashed n8n under some circumstances on shutdown or
workflow deactivate and so resulted in other workflows not getting
deactviated correctly.
This commit is contained in:
Jan Oberhauser
2022-03-12 19:50:42 +01:00
parent bb3fa05318
commit 195f104ef5
1 changed files with 20 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
packages/core/src/ActiveWorkflows.ts
View File

@@ -255,7 +255,16 @@ export class ActiveWorkflows {
if (workflowData.triggerResponses) { if (workflowData.triggerResponses) {
for (const triggerResponse of workflowData.triggerResponses) { for (const triggerResponse of workflowData.triggerResponses) {
if (triggerResponse.closeFunction) { if (triggerResponse.closeFunction) {
try {
await triggerResponse.closeFunction(); 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) { if (workflowData.pollResponses) {
for (const pollResponse of workflowData.pollResponses) { for (const pollResponse of workflowData.pollResponses) {
if (pollResponse.closeFunction) { if (pollResponse.closeFunction) {
try {
await pollResponse.closeFunction(); await pollResponse.closeFunction();
} catch (error) {
Logger.error(
`There was a problem deactivating polling trigger of workflow "${id}": "${error.message}"`,
{
workflowId: id,
},
);
}
} }
} }
} }