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

⚡ Wait for active workflow to finish before shutting down

Browse Source
This commit is contained in:
Jan Oberhauser
2020-09-14 12:30:58 +02:00
parent ae343b9f79
commit 397132688e
1 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
packages/cli/commands/start.ts
View File

@@ -8,12 +8,14 @@ const open = require('open');
import * as config from '../config'; import * as config from '../config';
import { import {
ActiveExecutions,
ActiveWorkflowRunner, ActiveWorkflowRunner,
CredentialTypes, CredentialTypes,
CredentialsOverwrites, CredentialsOverwrites,
Db, Db,
ExternalHooks, ExternalHooks,
GenericHelpers, GenericHelpers,
IExecutionsCurrentSummary,
LoadNodesAndCredentials, LoadNodesAndCredentials,
NodeTypes, NodeTypes,
Server, Server,
@@ -85,6 +87,21 @@ export class Start extends Command {
await Promise.all(removePromises); await Promise.all(removePromises);
// Wait for active workflow executions to finish
const activeExecutionsInstance = ActiveExecutions.getInstance();
let executingWorkflows = activeExecutionsInstance.getActiveExecutions();
let count = 0;
while (executingWorkflows.length !== 0) {
if (count++ % 4 === 0) {
console.log(`Waiting for ${executingWorkflows.length} active executions to finish...`);
}
await new Promise((resolve) => {
setTimeout(resolve, 500);
});
executingWorkflows = activeExecutionsInstance.getActiveExecutions();
}
process.exit(processExistCode); process.exit(processExistCode);
} }