mirror of
https://github.com/n8n-io/n8n.git
synced 2024-11-14 08:34:07 -08:00
Update worker command test
This commit is contained in:
parent
ee9ef30cab
commit
a1e3001251
|
@ -13,7 +13,6 @@ import { ExternalSecretsManager } from '@/external-secrets/external-secrets-mana
|
|||
import { License } from '@/license';
|
||||
import { LoadNodesAndCredentials } from '@/load-nodes-and-credentials';
|
||||
import { Push } from '@/push';
|
||||
import { TaskRunnerProcess } from '@/runners/task-runner-process';
|
||||
import { TaskRunnerServer } from '@/runners/task-runner-server';
|
||||
import { Publisher } from '@/scaling/pubsub/publisher.service';
|
||||
import { Subscriber } from '@/scaling/pubsub/subscriber.service';
|
||||
|
@ -37,7 +36,6 @@ const logStreamingEventRelay = mockInstance(LogStreamingEventRelay);
|
|||
const scalingService = mockInstance(ScalingService);
|
||||
const orchestrationService = mockInstance(OrchestrationService);
|
||||
const taskRunnerServer = mockInstance(TaskRunnerServer);
|
||||
const taskRunnerProcess = mockInstance(TaskRunnerProcess);
|
||||
mockInstance(Publisher);
|
||||
mockInstance(Subscriber);
|
||||
mockInstance(Telemetry);
|
||||
|
@ -61,7 +59,6 @@ test('worker initializes all its components', async () => {
|
|||
expect(orchestrationService.init).toHaveBeenCalledTimes(1);
|
||||
expect(messageEventBus.send).toHaveBeenCalledTimes(1);
|
||||
expect(taskRunnerServer.start).toHaveBeenCalledTimes(1);
|
||||
expect(taskRunnerProcess.start).toHaveBeenCalledTimes(1);
|
||||
|
||||
expect(config.getEnv('executions.mode')).toBe('queue');
|
||||
});
|
||||
|
|
Loading…
Reference in a new issue