We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5dd92c6 commit 163859bCopy full SHA for 163859b
packages/cli/src/commands/webhook.ts
@@ -3,6 +3,7 @@ import { LoggerProxy, sleep } from 'n8n-workflow';
3
import config from '@/config';
4
import { ActiveExecutions } from '@/ActiveExecutions';
5
import { WebhookServer } from '@/WebhookServer';
6
+import { Queue } from '@/Queue';
7
import { BaseCommand } from './BaseCommand';
8
import { Container } from 'typedi';
9
@@ -79,6 +80,7 @@ export class Webhook extends BaseCommand {
79
80
}
81
82
async run() {
83
+ await Container.get(Queue).init();
84
await new WebhookServer().start();
85
this.logger.info('Webhook listener waiting for requests.');
86
0 commit comments