add job controller

pluralsh · Apr 30, 2024 · f336df0 · f336df0
1 parent 4cc3821
commit f336df0
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/cmd/main.go b/cmd/main.go
@@ -104,6 +104,14 @@ func main() {
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "HealthConvert")
 	}
+	if err = (&controller.StackRunJobReconciler{
+		Client:        mgr.GetClient(),
+		Scheme:        mgr.GetScheme(),
+		ConsoleClient: ctrlMgr.GetClient(),
+	}).SetupWithManager(mgr); err != nil {
+		setupLog.Error(err, "unable to create controller", "controller", "StackRun")
+	}
+
 	//+kubebuilder:scaffold:builder
 
 	if err = (&controller.PipelineGateReconciler{

diff --git a/internal/controller/stackrunjob_controller.go b/internal/controller/stackrunjob_controller.go
@@ -144,7 +144,7 @@ func getExitCodeStatus(exitCode int32) console.StackStatus {
 }
 
 func getStackRunID(job *batchv1.Job) string {
-	return strings.TrimPrefix("stack-", job.Name)
+	return strings.TrimPrefix(job.Name, "stack-")
 }
 
 // SetupWithManager sets up the controller with the Manager.