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,