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()