this should work

2021-12-14 18:05:35 +01:00 · 2021-12-14 18:05:35 +01:00 · 264c3afde2
commit 264c3afde2
parent 13079cfa44
2 changed files with 5 additions and 1 deletions
--- a/job_orchestrator_service/utils/kubernetes_adapter.py
+++ b/job_orchestrator_service/utils/kubernetes_adapter.py
@ -35,5 +35,9 @@ class FlaskKubernetes:
    def corev1api(self) -> kubernetes.client.CoreV1Api:
        return kubernetes.client.CoreV1Api(self.connection)

+    @property
+    def customobjectsapi(self) -> kubernetes.client.CustomObjectsApi:
+        return kubernetes.client.CustomObjectsApi(self.connection)
+

 k8s = FlaskKubernetes()
--- a/job_orchestrator_service/views/job_view.py
+++ b/job_orchestrator_service/views/job_view.py
@ -226,7 +226,7 @@ class JobView(FlaskView):
            version = 'v1beta1'
            plural = 'federatedjobs'

-            r = k8s.connection.create_namespaced_custom_object(
+            r = k8s.customobjectsapi.create_namespaced_custom_object(
                group, version, current_app.config['WORKING_NAMESPACE'], plural, pod_object
            )