Merge branch 'master' into feature/SK-1202

scaleoutsystems · Nov 29, 2024 · ce57158 · ce57158
2 parents 9d8b91d + 343088c
commit ce57158
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/fedn/network/clients/grpc_handler.py b/fedn/network/clients/grpc_handler.py
@@ -1,4 +1,4 @@
-import json
+simport json
 import os
 import socket
 import time
@@ -177,7 +177,7 @@ def listen_to_task_stream(self, client_name: str, client_id: str, callback: Call
                     callback(request)
 
         except grpc.RpcError as e:
-            self.logger.error(f"GRPC (TaskStream): An error occurred: {e}")
+            logger.error(f"GRPC (TaskStream): An error occurred: {e}")
             return self._handle_grpc_error(e, "TaskStream", lambda: self.listen_to_task_stream(client_name, client_id, callback))
         except Exception as e:
             logger.error(f"GRPC (TaskStream): An error occurred: {e}")