From 4c98108d3e998e9d982239fe636579b4c856a924 Mon Sep 17 00:00:00 2001 From: Alex Cheema Date: Tue, 12 Nov 2024 20:30:25 +0400 Subject: [PATCH] increase grpc msg limit --- exo/networking/grpc/grpc_peer_handle.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/exo/networking/grpc/grpc_peer_handle.py b/exo/networking/grpc/grpc_peer_handle.py index bdaf20390..11fbb48fa 100644 --- a/exo/networking/grpc/grpc_peer_handle.py +++ b/exo/networking/grpc/grpc_peer_handle.py @@ -32,7 +32,11 @@ def device_capabilities(self) -> DeviceCapabilities: async def connect(self): if self.channel is None: - self.channel = grpc.aio.insecure_channel(self.address, options=[("grpc.max_metadata_size", 32*1024*1024)]) + self.channel = grpc.aio.insecure_channel(self.address, options=[ + ("grpc.max_metadata_size", 32*1024*1024), + ('grpc.max_receive_message_length', 32*1024*1024), + ('grpc.max_send_message_length', 32*1024*1024) + ]) self.stub = node_service_pb2_grpc.NodeServiceStub(self.channel) await self.channel.channel_ready()