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

⚡ Change same-process-execution setting to make it future proof

Browse source
This commit is contained in:
Jan Oberhauser 2020-01-17 19:49:31 -06:00
parent 95cb1b2788
commit e5ae4c77eb
4 changed files with 16 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
docs/configuration.md
View file

@ -87,7 +87,7 @@ workflows are not CPU intensive and they have to start very fast it is possible
all directly in the main-process with this setting.
```bash
export EXECUTIONS_SAME_PROCESS=true
export EXECUTIONS_PROCESS=main
```

17
packages/cli/config/index.ts
View file

@ -55,6 +55,17 @@ const config = convict({
},
executions: {
// By default workflows get always executed in their own process.
// If this option gets set to "main" it will run them in the
// main-process instead.
process: {
doc: 'In what process workflows should be executed',
format: ['main', 'own'],
default: 'own',
env: 'EXECUTIONS_PROCESS'
},
// If a workflow executes all the data gets saved by default. This
// could be a problem when a workflow gets executed a lot and processes
// a lot of data. To not write the database full it is possible to
@ -84,12 +95,6 @@ const config = convict({
default: false,
env: 'EXECUTIONS_DATA_SAVE_MANUAL_EXECUTIONS'
},
sameProcessExecution: {
doc: 'Executes the workflows in the same process instead of in a separate one',
default: false,
env: 'EXECUTIONS_SAME_PROCESS'
},
},
generic: {

8
packages/cli/src/WorkflowRunner.ts
View file

@ -94,9 +94,9 @@ export class WorkflowRunner {
* @memberof WorkflowRunner
*/
async run(data: IWorkflowExecutionDataProcess, loadStaticData?: boolean): Promise<string> {
const sameProcessExecution = config.get('executions.sameProcessExecution') as boolean;
if (sameProcessExecution === true) {
return this.runSameProcess(data, loadStaticData);
const executionsProcess = config.get('executions.process') as string;
if (executionsProcess === 'main') {
return this.runMainProcess(data, loadStaticData);
}
return this.runSubprocess(data, loadStaticData);
@ -112,7 +112,7 @@ export class WorkflowRunner {
* @returns {Promise<string>}
* @memberof WorkflowRunner
*/
async runSameProcess(data: IWorkflowExecutionDataProcess, loadStaticData?: boolean): Promise<string> {
async runMainProcess(data: IWorkflowExecutionDataProcess, loadStaticData?: boolean): Promise<string> {
if (loadStaticData === true && data.workflowData.id) {
data.workflowData.staticData = await WorkflowHelpers.getStaticDataById(data.workflowData.id as string);
}

2
packages/core/src/WorkflowExecute.ts
View file

@ -478,8 +478,6 @@ export class WorkflowExecute {
onCancel.shouldReject = false;
onCancel(() => {
console.log('got cancellled');
gotCancel = true;
});