fix SendNewToken

cb4615c95d8565e76a1fea4a17dc5485e285e5af · 2024-12-14 21:11:00 +0000 · Alex Cheema

Files touched

M exo/networking/grpc/grpc_server.py

Diff

commit cb4615c95d8565e76a1fea4a17dc5485e285e5af
Author: Alex Cheema <alexcheema123@gmail.com>
Date:   Sat Dec 14 21:11:00 2024 +0000

    fix SendNewToken
---
 exo/networking/grpc/grpc_server.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/exo/networking/grpc/grpc_server.py b/exo/networking/grpc/grpc_server.py
index c6a56685..a22f3e68 100644
--- a/exo/networking/grpc/grpc_server.py
+++ b/exo/networking/grpc/grpc_server.py
@@ -118,12 +118,12 @@ class GRPCServer(node_service_pb2_grpc.NodeServiceServicer):
     if DEBUG >= 5: print(f"CollectTopology {max_depth=} {visited=} {nodes=} {peer_graph=}")
     return node_service_pb2.Topology(nodes=nodes, peer_graph=peer_graph)
 
-  async def SendResult(self, request, context):
+  async def SendNewToken(self, request, context):
     request_id = request.request_id
-    result = request.result
+    token = request.token
     is_finished = request.is_finished
-    if DEBUG >= 5: print(f"Received SendResult request: {request_id=} {result=} {is_finished=}")
-    self.node.on_token.trigger_all(request_id, result, is_finished)
+    if DEBUG >= 5: print(f"Received SendNewToken request: {request_id=} {token=} {is_finished=}")
+    self.node.on_token.trigger_all(request_id, token, is_finished)
     return node_service_pb2.Empty()
 
   async def SendOpaqueStatus(self, request, context):

← f55a53ae one token at a time · back to Exo · rip out stats bloat 06c2e236 →