From ec4318a88a9563d340ef46c25612e0002b15d13d Mon Sep 17 00:00:00 2001 From: Eugene Molodkin Date: Mon, 6 Jan 2025 17:21:23 +0100 Subject: [PATCH] wip: fix log streaming type mismatch --- .../src/events/__tests__/log-streaming-event-relay.test.ts | 2 ++ packages/cli/src/events/relays/log-streaming.event-relay.ts | 4 ++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/packages/cli/src/events/__tests__/log-streaming-event-relay.test.ts b/packages/cli/src/events/__tests__/log-streaming-event-relay.test.ts index 4727c8ef72..1729509210 100644 --- a/packages/cli/src/events/__tests__/log-streaming-event-relay.test.ts +++ b/packages/cli/src/events/__tests__/log-streaming-event-relay.test.ts @@ -934,6 +934,7 @@ describe('LogStreamingEventRelay', () => { it('should log on `execution-throttled` event', () => { const event: RelayEventMap['execution-throttled'] = { executionId: 'exec123456', + type: 'production', }; eventService.emit('execution-throttled', event); @@ -942,6 +943,7 @@ describe('LogStreamingEventRelay', () => { eventName: 'n8n.execution.throttled', payload: { executionId: 'exec123456', + type: 'production', }, }); }); diff --git a/packages/cli/src/events/relays/log-streaming.event-relay.ts b/packages/cli/src/events/relays/log-streaming.event-relay.ts index b048b09a83..76b578451d 100644 --- a/packages/cli/src/events/relays/log-streaming.event-relay.ts +++ b/packages/cli/src/events/relays/log-streaming.event-relay.ts @@ -385,10 +385,10 @@ export class LogStreamingEventRelay extends EventRelay { // #region Execution - private executionThrottled({ executionId }: RelayEventMap['execution-throttled']) { + private executionThrottled({ executionId, type }: RelayEventMap['execution-throttled']) { void this.eventBus.sendExecutionEvent({ eventName: 'n8n.execution.throttled', - payload: { executionId }, + payload: { executionId, type }, }); }