Skip to content

Commit cea6677

Browse files
committed
test: get Kubernetes Jobs to run again
Signed-off-by: iripiri <[email protected]>
1 parent d78de89 commit cea6677

File tree

1 file changed

+10
-6
lines changed

1 file changed

+10
-6
lines changed

villas/controller/components/simulators/kubernetes.py

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -106,8 +106,8 @@ def _prepare_job(self, job, payload):
106106
job.metadata.generate_name = name + '-'
107107
job.metadata.name = None
108108

109-
if o := self._owner():
110-
job.metadata.owner_references = [o]
109+
# if o := self._owner():
110+
# job.metadata.owner_references = [o]
111111

112112
if job.metadata.labels is None:
113113
job.metadata.labels = {}
@@ -144,8 +144,8 @@ def _create_config_map(self, payload):
144144
}
145145
)
146146

147-
if o := self._owner():
148-
self.cm.metadata.owner_references = [o]
147+
# if o := self._owner():
148+
# self.cm.metadata.owner_references = [o]
149149

150150
return c.create_namespaced_config_map(
151151
namespace=self.manager.namespace,
@@ -165,8 +165,12 @@ def _delete_job(self):
165165
name=self.job.metadata.name,
166166
body=body)
167167
except k8s.client.exceptions.ApiException as e:
168-
raise SimulationException(self, 'Kubernetes API error',
169-
error=str(e))
168+
if e.status == 404:
169+
# Job does not exist, treat as already deleted
170+
return
171+
else:
172+
raise SimulationException(self, 'Kubernetes API error',
173+
error=str(e))
170174

171175
self.pods.clear()
172176

0 commit comments

Comments
 (0)