mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-03-05 20:50:17 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

wip: fix log streaming type mismatch

Browse source
This commit is contained in:
Eugene Molodkin 2025-01-06 17:21:23 +01:00
parent 29603f2dd5
commit ec4318a88a
No known key found for this signature in database
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/cli/src/events/__tests__/log-streaming-event-relay.test.ts
View file

@ -934,6 +934,7 @@ describe('LogStreamingEventRelay', () => {
it('should log on `execution-throttled` event', () => { it('should log on `execution-throttled` event', () => {
const event: RelayEventMap['execution-throttled'] = { const event: RelayEventMap['execution-throttled'] = {
executionId: 'exec123456', executionId: 'exec123456',
type: 'production',
}; };
eventService.emit('execution-throttled', event); eventService.emit('execution-throttled', event);
@ -942,6 +943,7 @@ describe('LogStreamingEventRelay', () => {
eventName: 'n8n.execution.throttled', eventName: 'n8n.execution.throttled',
payload: { payload: {
executionId: 'exec123456', executionId: 'exec123456',
type: 'production',
}, },
}); });
}); });

4
packages/cli/src/events/relays/log-streaming.event-relay.ts
View file

@ -385,10 +385,10 @@ export class LogStreamingEventRelay extends EventRelay {
// #region Execution // #region Execution
private executionThrottled({ executionId }: RelayEventMap['execution-throttled']) { private executionThrottled({ executionId, type }: RelayEventMap['execution-throttled']) {
void this.eventBus.sendExecutionEvent({ void this.eventBus.sendExecutionEvent({
eventName: 'n8n.execution.throttled', eventName: 'n8n.execution.throttled',
payload: { executionId }, payload: { executionId, type },
}); });
} }