Added exception when abort fails

2021-04-19 01:49:03 +02:00
parent 800ed14449
commit b62ebc85f9
1 changed files with 2 additions and 1 deletions
--- a/job_orchestrator_service/views/job_view.py
+++ b/job_orchestrator_service/views/job_view.py
@@ -212,7 +212,8 @@ class JobView(FlaskView):
                    raise

            if r.status.phase not in ['Succeeded', 'Failed']:
-                requests.post(f"http://{r.status.pod_ip}:{self.CONTROLLER_HTTP_PORT}/abort")
+                r = requests.post(f"http://{r.status.pod_ip}:{self.CONTROLLER_HTTP_PORT}/abort")
+                r.raise_for_status()
                self._k8s_wait_pod_phase(pod_name, ['Succeeded', 'Failed'])

            try: