mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-11-14 08:34:07 -08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Encapsulate better

Browse source
This commit is contained in:
Iván Ovejero 2024-11-07 16:20:49 +01:00
parent c513335054
commit b786d91841
No known key found for this signature in database
1 changed files with 26 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
packages/cli/src/runners/task-broker.service.ts
View file

@ -557,6 +557,10 @@ export class TaskBroker {
}
}
/**
* Whether n8n should manage the runner's lifecycle, i.e. launch it on demand,
* keep it alive for a period of time, and shut it down when idle for too long.
*/
private get shouldManageLifecycle() {
return (
this.runnerConfig.mode === 'internal_childprocess' ||
@ -564,23 +568,32 @@ export class TaskBroker {
);
}
async taskRequested(request: TaskRequest) {
if (this.shouldManageLifecycle) {
const { RunnerLifecycleManager } = await import('@/runners/runner-lifecycle-manager');
const lifecycleManager = Container.get(RunnerLifecycleManager);
/**
* Whether the runner is ready to accept a task, waiting one to launch if needed.
* Only for modes where we manage the runner's lifecycle.
*/
private async isRunnerReady(request: TaskRequest) {
const { RunnerLifecycleManager } = await import('@/runners/runner-lifecycle-manager');
const lifecycleManager = Container.get(RunnerLifecycleManager);
try {
await lifecycleManager.ensureRunnerAvailable();
} catch (e) {
const error = ensureError(e);
this.logger.error('Failed to start task runner', { error });
this.handleRunnerReject(request.requestId, `Task runner unavailable: ${error.message}`);
return;
}
try {
await lifecycleManager.ensureRunnerAvailable();
} catch (e) {
const error = ensureError(e);
this.logger.error('Failed to start task runner', { error });
this.handleRunnerReject(request.requestId, `Task runner unavailable: ${error.message}`);
lifecycleManager.updateLastActivityTime();
return false;
}
lifecycleManager.updateLastActivityTime();
return true;
}
async taskRequested(request: TaskRequest) {
if (this.shouldManageLifecycle && !(await this.isRunnerReady(request))) return;
this.pendingTaskRequests.push(request);
this.settleTasks();
}