Skip to content

Commit

Permalink
fix(core): Prevent shutdown error in regular mode (#10844)
Browse files Browse the repository at this point in the history
  • Loading branch information
ivov authored Sep 17, 2024
1 parent 5a2c7e0 commit acb4194
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion packages/cli/src/commands/worker.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@ import { MessageEventBus } from '@/eventbus/message-event-bus/message-event-bus'
import { LogStreamingEventRelay } from '@/events/log-streaming-event-relay';
import { JobProcessor } from '@/scaling/job-processor';
import type { ScalingService } from '@/scaling/scaling.service';
import { WorkerServer } from '@/scaling/worker-server';
import { OrchestrationHandlerWorkerService } from '@/services/orchestration/worker/orchestration.handler.worker.service';
import { OrchestrationWorkerService } from '@/services/orchestration/worker/orchestration.worker.service';
import type { RedisServicePubSubSubscriber } from '@/services/redis/redis-service-pub-sub-subscriber';
Expand Down Expand Up @@ -167,6 +166,7 @@ export class Worker extends BaseCommand {
this.globalConfig.queue.health.active ||
this.globalConfig.credentials.overwrite.endpoint !== ''
) {
const { WorkerServer } = await import('@/scaling/worker-server');
await Container.get(WorkerServer).init();
}

Expand Down

0 comments on commit acb4194

Please sign in to comment.