theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/TheodoliteOperator.kt

@@ -67,15 +67,16 @@ class TheodoliteOperator {
                 client = client
             ).clearClusterState()
 
-            getController(
+            controller = getController(
                 client = client,
                 executionStateHandler = getExecutionStateHandler(client = client)
-            ).run()
-            getExecutionEventHandler(client).startAllRegisteredInformers()
+            )
+            getExecutionEventHandler(controller, client).startAllRegisteredInformers()
+            controller.run()
         }
     }
 
-    fun getExecutionEventHandler(client: NamespacedKubernetesClient): SharedInformerFactory {
+    fun getExecutionEventHandler(controller: TheodoliteController, client: NamespacedKubernetesClient): SharedInformerFactory {
         val factory = client.informers()
             .inNamespace(client.namespace)
 

theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/ExecutionEventHandlerTest.kt

@@ -39,7 +39,7 @@ class ExecutionEventHandlerTest {
             executionStateHandler = ExecutionStateHandler(client = server.client)
         )
 
-        this.factory = operator.getExecutionEventHandler(server.client)
+        this.factory = operator.getExecutionEventHandler(this.controller,server.client)
         this.stateHandler = TheodoliteOperator().getExecutionStateHandler(client = server.client)
 
         this.executionVersion1 = K8sResourceLoader(server.client)