From e67ad2962589b445592641a588024c02b4d99d3f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E0=A4=95=E0=A4=BE=E0=A4=B0=E0=A4=A4=E0=A5=8B=E0=A4=AB?= =?UTF-8?q?=E0=A5=8D=E0=A4=AB=E0=A5=87=E0=A4=B2=E0=A4=B8=E0=A5=8D=E0=A4=95?= =?UTF-8?q?=E0=A5=8D=E0=A4=B0=E0=A4=BF=E0=A4=AA=E0=A5=8D=E0=A4=9F=E2=84=A2?= Date: Fri, 24 Mar 2023 10:47:21 +0100 Subject: [PATCH] fix(core): Initialize queue in the webhook server as well (#5766) fix(core): Initialize queue in the webhook server as well (no-changelog) --- packages/cli/src/commands/webhook.ts | 2 ++ 1 file changed, 2 insertions(+) diff --git a/packages/cli/src/commands/webhook.ts b/packages/cli/src/commands/webhook.ts index aada27f3cdc03..cc1ac53b35389 100644 --- a/packages/cli/src/commands/webhook.ts +++ b/packages/cli/src/commands/webhook.ts @@ -3,6 +3,7 @@ import { LoggerProxy, sleep } from 'n8n-workflow'; import config from '@/config'; import { ActiveExecutions } from '@/ActiveExecutions'; import { WebhookServer } from '@/WebhookServer'; +import { Queue } from '@/Queue'; import { BaseCommand } from './BaseCommand'; import { Container } from 'typedi'; @@ -79,6 +80,7 @@ export class Webhook extends BaseCommand { } async run() { + await Container.get(Queue).init(); await new WebhookServer().start(); this.logger.info('Webhook listener waiting for requests.');