Ver Fonte

fix: await unary handler response

Denis Mazur há 4 anos atrás
pai
commit
e87d8628a3
1 ficheiros alterados com 1 adições e 1 exclusões
  1. 1 1
      hivemind/p2p/p2p_daemon_bindings/control.py

+ 1 - 1
hivemind/p2p/p2p_daemon_bindings/control.py

@@ -133,7 +133,7 @@ class ControlClient:
 
         try:
             remote_id = PeerID(request.peer)
-            response_payload: bytes = self.unary_handlers[request.proto](request.data, remote_id)
+            response_payload: bytes = await self.unary_handlers[request.proto](request.data, remote_id)
             response = p2pd_pb.CallUnaryResponse(callId=request.callId, result=response_payload)
         except Exception as e:
             response = p2pd_pb.CallUnaryResponse(callId=request.callId, error=repr(e))