Ruff

Author: aversey

locust_benchmark/create_feature_group.py

@@ -1,7 +1,6 @@
 from common.hopsworks_client import HopsworksClient
 
 if __name__ == "__main__":
-
     hopsworks_client = HopsworksClient()
     fg = hopsworks_client.get_or_create_fg()
     hopsworks_client.insert_data(fg)

python/hsml/core/serving_api.py

@@ -291,7 +291,9 @@ def _send_inference_request_via_grpc_protocol(
             # the channel, which will be reused in all following calls on the same deployment object.
             # The gRPC channel is freed when calling deployment.stop()
             print("Initializing gRPC channel...")
-            deployment_instance._grpc_channel = self._create_grpc_channel(deployment_instance)
+            deployment_instance._grpc_channel = self._create_grpc_channel(
+                deployment_instance
+            )
         # build an infer request
         request = InferRequest(
             infer_inputs=data,

utils/python/hsfs_utils.py

@@ -318,4 +318,3 @@ def parse_isoformat_date(da: str) -> datetime:
             sys.exit(1)
 
     sys.exit(0)
-