fix

logicalclocks · Feb 5, 2024 · 3f10757 · 3f10757
1 parent 15b36fd
commit 3f10757
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/python/hopsworks/engine/execution_engine.py b/python/hopsworks/engine/execution_engine.py
@@ -52,7 +52,7 @@ def download_logs(self, execution, path=None):
         if not os.path.exists(download_log_dir):
             os.mkdir(download_log_dir)
 
-        max_num_retries=12
+        max_num_retries = 12
         retries = 0
 
         out_path = None
@@ -67,9 +67,9 @@ def download_logs(self, execution, path=None):
                     break
                 except RestAPIError as e:
                     if (
-                            e.response.json().get("errorCode", "") == 110021
-                            and e.response.status_code == 400
-                            and retries < max_num_retries
+                        e.response.json().get("errorCode", "") == 110021
+                        and e.response.status_code == 400
+                        and retries < max_num_retries
                     ):
                         retries += 1
                         time.sleep(5)
@@ -89,9 +89,9 @@ def download_logs(self, execution, path=None):
                     break
                 except RestAPIError as e:
                     if (
-                            e.response.json().get("errorCode", "") == 110021
-                            and e.response.status_code == 400
-                            and retries < max_num_retries
+                        e.response.json().get("errorCode", "") == 110021
+                        and e.response.status_code == 400
+                        and retries < max_num_retries
                     ):
                         retries += 1
                         time.sleep(5)