From 085c23f66ab3f0a0bbe2970a8fac73b77791cfe8 Mon Sep 17 00:00:00 2001 From: Jeremie Fraeys Date: Tue, 17 Feb 2026 16:40:03 -0500 Subject: [PATCH] refactor(phase7): Initialize JobRunner in factory.go - Create jobRunner using NewJobRunner with local and container executors - Assign jobRunner to Worker.runner field - JobRunner available for future task execution orchestration Build status: Compiles successfully --- internal/worker/factory.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/internal/worker/factory.go b/internal/worker/factory.go index 22543b0..3e9e312 100644 --- a/internal/worker/factory.go +++ b/internal/worker/factory.go @@ -126,6 +126,14 @@ func NewWorker(cfg *Config, _ string) (*Worker, error) { cfg.LocalMode, ) + // Create job runner + jobRunner := executor.NewJobRunner( + localExecutor, + containerExecutor, + nil, // ManifestWriter - can be added later if needed + logger, + ) + runLoop := lifecycle.NewRunLoop( runLoopConfig, queueClient, @@ -150,6 +158,7 @@ func NewWorker(cfg *Config, _ string) (*Worker, error) { config: cfg, logger: logger, runLoop: runLoop, + runner: jobRunner, metrics: metricsObj, health: lifecycle.NewHealthMonitor(), resources: rm,