increase grpc msg limit

4c98108d3e998e9d982239fe636579b4c856a924 · 2024-11-12 20:30:25 +0400 · Alex Cheema

Files touched

M exo/networking/grpc/grpc_peer_handle.py

Diff

commit 4c98108d3e998e9d982239fe636579b4c856a924
Author: Alex Cheema <alexcheema123@gmail.com>
Date:   Tue Nov 12 20:30:25 2024 +0400

    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 bdaf2039..11fbb48f 100644
--- a/exo/networking/grpc/grpc_peer_handle.py
+++ b/exo/networking/grpc/grpc_peer_handle.py
@@ -32,7 +32,11 @@ class GRPCPeerHandle(PeerHandle):
 
   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()

← 19463737 fix debug log · back to Exo · removing timeout for error and adding close button cbe551d1 →