ruff format

python/hopsworks/core/environment_api.py

@@ -31,7 +31,13 @@ def __init__(
 
         self._environment_engine = environment_engine.EnvironmentEngine(project_id)
 
-    def create_environment(self, name: str, description: Optional[str] = None, base_environment_name: Optional[str] = "python-feature-pipeline", await_creation: Optional[bool] = True) -> environment.Environment:
+    def create_environment(
+        self,
+        name: str,
+        description: Optional[str] = None,
+        base_environment_name: Optional[str] = "python-feature-pipeline",
+        await_creation: Optional[bool] = True,
+    ) -> environment.Environment:
         """Create Python environment for the project
 
         ```python
@@ -65,13 +71,14 @@ def create_environment(self, name: str, description: Optional[str] = None, base_
             name,
         ]
         headers = {"content-type": "application/json"}
-        data = {"name": name,
-                "baseImage": {
-                    "name": base_environment_name,
-                    "description": description
-                }}
+        data = {
+            "name": name,
+            "baseImage": {"name": base_environment_name, "description": description},
+        }
         env = environment.Environment.from_response_json(
-            _client._send_request("POST", path_params, headers=headers, data=json.dumps(data)),
+            _client._send_request(
+                "POST", path_params, headers=headers, data=json.dumps(data)
+            ),
             self._project_id,
             self._project_name,
         )
@@ -142,4 +149,4 @@ def _delete(self, name):
             name,
         ]
         headers = {"content-type": "application/json"}
-        _client._send_request("DELETE", path_params, headers=headers),
+        (_client._send_request("DELETE", path_params, headers=headers),)

python/hopsworks/core/secret_api.py

@@ -72,7 +72,9 @@ def get_secret(self, name: str, owner: str = None) -> secret.Secret:
                 "shared",
             ]
 
-        return secret.Secret.from_response_json(_client._send_request("GET", path_params, query_params=query_params))[0]
+        return secret.Secret.from_response_json(
+            _client._send_request("GET", path_params, query_params=query_params)
+        )[0]
 
     def get(self, name: str, owner: str = None) -> str:
         """Get the secret's value.
@@ -90,16 +92,20 @@ def get(self, name: str, owner: str = None) -> str:
             return self.get_secret(name=name, owner=owner).value
         except RestAPIError as e:
             if (
-                    e.response.json().get("errorCode", "") == 160048
-                    and e.response.status_code == 404
-                    and util.is_interactive()
+                e.response.json().get("errorCode", "") == 160048
+                and e.response.status_code == 404
+                and util.is_interactive()
             ):
-                secret_input = getpass.getpass(prompt="\nCould not find secret, enter value here to create it: ")
+                secret_input = getpass.getpass(
+                    prompt="\nCould not find secret, enter value here to create it: "
+                )
                 return self.create_secret(name, secret_input).value
             else:
                 raise e
 
-    def create_secret(self, name: str, value: str, project: str = None) -> secret.Secret:
+    def create_secret(
+        self, name: str, value: str, project: str = None
+    ) -> secret.Secret:
         """Create a new secret.
 
         ```python

python/hopsworks/environment.py

@@ -131,12 +131,12 @@ def install_wheel(self, path, await_installation: Optional[bool] = True):
             "packageSource": "WHEEL",
         }
 
-        library_rest = self._library_api.install(
-            library_name, self.name, library_spec
-        )
+        library_rest = self._library_api.install(library_name, self.name, library_spec)
 
         if await_installation:
-            return self._environment_engine.await_library_command(self.name, library_name)
+            return self._environment_engine.await_library_command(
+                self.name, library_name
+            )
 
         return library_rest
 
@@ -180,12 +180,12 @@ def install_requirements(self, path, await_installation: Optional[bool] = True):
             "packageSource": "REQUIREMENTS_TXT",
         }
 
-        library_rest = self._library_api.install(
-            library_name, self.name, library_spec
-        )
+        library_rest = self._library_api.install(library_name, self.name, library_spec)
 
         if await_installation:
-            return self._environment_engine.await_library_command(self.name, library_name)
+            return self._environment_engine.await_library_command(
+                self.name, library_name
+            )
 
         return library_rest
 

python/hopsworks/job_schedule.py

@@ -30,7 +30,7 @@ def __init__(
         next_execution_date_time=None,
         id=None,
         end_date_time=None,
-        **kwargs
+        **kwargs,
     ):
         self._id = id
         self._start_date_time = (

python/hopsworks/project.py

@@ -103,7 +103,9 @@ def created(self):
         """Timestamp when the project was created"""
         return self._created
 
-    def get_feature_store(self, name: str = None, engine: str = None) -> feature_store.FeatureStore:
+    def get_feature_store(
+        self, name: str = None, engine: str = None
+    ) -> feature_store.FeatureStore:
         """Connect to Project's Feature Store.
 
         Defaulting to the project name of default feature store. To get a
@@ -142,7 +144,9 @@ def get_feature_store(self, name: str = None, engine: str = None) -> feature_sto
                 engine=engine,
             ).get_feature_store(name)
         else:
-            return connection(engine=engine).get_feature_store(name)  # If internal client
+            return connection(engine=engine).get_feature_store(
+                name
+            )  # If internal client
 
     def get_model_registry(self):
         """Connect to Project's Model Registry API.

python/hopsworks/util.py

@@ -81,6 +81,8 @@ def get_hostname_replaced_url(sub_path: str):
     url_parsed = client.get_instance().replace_public_host(urlparse(href))
     return url_parsed.geturl()
 
+
 def is_interactive():
     import __main__ as main
-    return not hasattr(main, '__file__')
+
+    return not hasattr(main, "__file__")

python/tests/hopsworks/test_login.py

@@ -63,7 +63,6 @@ def tearDown(self):
         hopsworks.logout()
 
     def _check_api_key_existence(self):
-
         path = hopsworks._get_cached_api_key_path()
 
         api_key_name = ".hw_api_key"