test: get Kubernetes Jobs to run again

Signed-off-by: iripiri <[email protected]>

Author: iripiri

villas/controller/components/simulators/kubernetes.py

@@ -106,8 +106,8 @@ def _prepare_job(self, job, payload):
         job.metadata.generate_name = name + '-'
         job.metadata.name = None
 
-        if o := self._owner():
-            job.metadata.owner_references = [o]
+#        if o := self._owner():
+#            job.metadata.owner_references = [o]
 
         if job.metadata.labels is None:
             job.metadata.labels = {}
@@ -144,8 +144,8 @@ def _create_config_map(self, payload):
             }
         )
 
-        if o := self._owner():
-            self.cm.metadata.owner_references = [o]
+#        if o := self._owner():
+#            self.cm.metadata.owner_references = [o]
 
         return c.create_namespaced_config_map(
             namespace=self.manager.namespace,
@@ -165,8 +165,12 @@ def _delete_job(self):
                 name=self.job.metadata.name,
                 body=body)
         except k8s.client.exceptions.ApiException as e:
-            raise SimulationException(self, 'Kubernetes API error',
-                                      error=str(e))
+            if e.status == 404:
+                # Job does not exist, treat as already deleted
+                return
+            else:
+                raise SimulationException(self, 'Kubernetes API error',
+                                          error=str(e))
 
         self.pods.clear()
 
@@ -228,6 +232,7 @@ def resume(self, payload):
 
     def reset(self, payload):
         self.change_state('resetting', True)
+        self.mixin.drain_publish_queue()
         self._delete_job()
         super().reset(payload)