From 9b7c8747788ca5bf90a9254be553d5b27e5f7104 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Iv=C3=A1n=20Ovejero?= Date: Tue, 13 Aug 2024 13:22:55 +0200 Subject: [PATCH] Fix test --- .../cli/src/services/__tests__/orchestration.service.test.ts | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/packages/cli/src/services/__tests__/orchestration.service.test.ts b/packages/cli/src/services/__tests__/orchestration.service.test.ts index c69e674613e25..ed4883768ce08 100644 --- a/packages/cli/src/services/__tests__/orchestration.service.test.ts +++ b/packages/cli/src/services/__tests__/orchestration.service.test.ts @@ -19,6 +19,7 @@ import { Push } from '@/push'; import { ActiveWorkflowManager } from '@/ActiveWorkflowManager'; import { mockInstance } from '@test/mocking'; import { RedisClientService } from '@/services/redis/redis-client.service'; +import type { MainResponseReceivedHandlerOptions } from '../orchestration/main/types'; const instanceSettings = Container.get(InstanceSettings); const redisClientService = mockInstance(RedisClientService); @@ -96,8 +97,9 @@ describe('Orchestration Service', () => { test('should handle worker responses', async () => { const response = await handleWorkerResponseMessageMain( JSON.stringify(workerRestartEventBusResponse), + mock(), ); - expect(response.command).toEqual('restartEventBus'); + expect(response?.command).toEqual('restartEventBus'); }); test('should handle command messages from others', async () => {