mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-12-24 04:04:06 -08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

🐛 Fix execute commands after binary data release (#2628)

Browse source
This commit is contained in:
Omar Ajoue 2022-01-03 22:49:44 +01:00 committed by GitHub
parent 224ef736de
commit baa43c1e33
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
packages/cli/commands/execute.ts
View file

@ -2,7 +2,7 @@
/* eslint-disable no-console */ /* eslint-disable no-console */
import { promises as fs } from 'fs'; import { promises as fs } from 'fs';
import { Command, flags } from '@oclif/command'; import { Command, flags } from '@oclif/command';
import { UserSettings } from 'n8n-core'; import { BinaryDataManager, IBinaryDataConfig, UserSettings } from 'n8n-core';
import { INode, LoggerProxy } from 'n8n-workflow'; import { INode, LoggerProxy } from 'n8n-workflow';
import { import {
@ -22,6 +22,7 @@ import {
} from '../src'; } from '../src';
import { getLogger } from '../src/Logger'; import { getLogger } from '../src/Logger';
import config = require('../config');
export class Execute extends Command { export class Execute extends Command {
static description = '\nExecutes a given workflow'; static description = '\nExecutes a given workflow';
@ -45,6 +46,8 @@ export class Execute extends Command {
async run() { async run() {
const logger = getLogger(); const logger = getLogger();
LoggerProxy.init(logger); LoggerProxy.init(logger);
const binaryDataConfig = config.get('binaryDataManager') as IBinaryDataConfig;
await BinaryDataManager.init(binaryDataConfig, true);
// eslint-disable-next-line @typescript-eslint/no-shadow // eslint-disable-next-line @typescript-eslint/no-shadow
const { flags } = this.parse(Execute); const { flags } = this.parse(Execute);

5
packages/cli/commands/executeBatch.ts
View file

@ -9,7 +9,7 @@
import * as fs from 'fs'; import * as fs from 'fs';
import { Command, flags } from '@oclif/command'; import { Command, flags } from '@oclif/command';
import { UserSettings } from 'n8n-core'; import { BinaryDataManager, IBinaryDataConfig, UserSettings } from 'n8n-core';
// eslint-disable-next-line @typescript-eslint/no-unused-vars // eslint-disable-next-line @typescript-eslint/no-unused-vars
import { INode, ITaskData, LoggerProxy } from 'n8n-workflow'; import { INode, ITaskData, LoggerProxy } from 'n8n-workflow';
@ -36,6 +36,7 @@ import {
NodeTypes, NodeTypes,
WorkflowRunner, WorkflowRunner,
} from '../src'; } from '../src';
import config = require('../config');
export class ExecuteBatch extends Command { export class ExecuteBatch extends Command {
static description = '\nExecutes multiple workflows once'; static description = '\nExecutes multiple workflows once';
@ -190,6 +191,8 @@ export class ExecuteBatch extends Command {
const logger = getLogger(); const logger = getLogger();
LoggerProxy.init(logger); LoggerProxy.init(logger);
const binaryDataConfig = config.get('binaryDataManager') as IBinaryDataConfig;
await BinaryDataManager.init(binaryDataConfig, true);
// eslint-disable-next-line @typescript-eslint/no-shadow // eslint-disable-next-line @typescript-eslint/no-shadow
const { flags } = this.parse(ExecuteBatch); const { flags } = this.parse(ExecuteBatch);