File size: 1,638 Bytes
aec3094 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 | import type { TaskRunnerMode } from '@n8n/config/src/configs/runners.config';
import { OperationalError } from 'n8n-workflow';
export class TaskRunnerExecutionTimeoutError extends OperationalError {
description: string;
constructor({
taskTimeout,
isSelfHosted,
mode,
}: { taskTimeout: number; isSelfHosted: boolean; mode: TaskRunnerMode }) {
super(
`Task execution timed out after ${taskTimeout} ${taskTimeout === 1 ? 'second' : 'seconds'}`,
);
const subtitles = {
internal:
'The task runner was taking too long on this task, so it was suspected of being unresponsive and restarted, and the task was aborted.',
external: 'The task runner was taking too long on this task, so the task was aborted.',
};
const fixes = {
optimizeScript:
'Optimize your script to prevent long-running tasks, e.g. by processing data in smaller batches.',
ensureTermination:
'Ensure that all paths in your script are able to terminate, i.e. no infinite loops.',
increaseTimeout: `If your task can reasonably take more than ${taskTimeout} ${taskTimeout === 1 ? 'second' : 'seconds'}, increase the timeout using the N8N_RUNNERS_TASK_TIMEOUT environment variable.`,
};
const suggestions = [fixes.optimizeScript, fixes.ensureTermination];
if (isSelfHosted) suggestions.push(fixes.increaseTimeout);
const suggestionsText = suggestions
.map((suggestion, index) => `${index + 1}. ${suggestion}`)
.join('<br/>');
const description = `${mode === 'internal' ? subtitles.internal : subtitles.external} You can try the following:<br/><br/>${suggestionsText}`;
this.description = description;
}
}
|