diff --git a/fedn/network/clients/grpc_handler.py b/fedn/network/clients/grpc_handler.py index 0aeedf34..898f3bb6 100644 --- a/fedn/network/clients/grpc_handler.py +++ b/fedn/network/clients/grpc_handler.py @@ -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}")