feat: enhance worker functionality by adding job queuing for deploy_apply. Introduce a Registry field in the Worker struct and implement enqueueDeployAllSpeakers method to streamline job processing after refresh or rollback operations, improving deployment efficiency.

2026-04-06 16:32:23 +07:00
parent e20c9f3113
commit 42d956d109
2 changed files with 26 additions and 0 deletions
@@ -47,6 +47,7 @@ func BootstrapWorkers(ctx context.Context, opts Options) (store.Backend, *jobs.R
 	cdnHTTP := &http.Client{Timeout: 45 * time.Second}
 	wk := &jobs.Worker{Store: backend, HTTPClient: cdnHTTP}
 	reg := jobs.NewRegistry(wk.Process)
+	wk.Registry = reg
 	observability.RegisterStoreBackend(backend)
 	return backend, reg, pool, nil
 }