Merge branch 'unary-handlers' of github.com:learning-at-home/hivemind into unary-handlers

hivemind/p2p/p2p_daemon_bindings/control.py

@@ -86,7 +86,7 @@ class ControlClient:
 
         self._ensure_conn_lock = asyncio.Lock()
         self.pending_messages: asyncio.Queue[p2pd_pb.Request] = asyncio.Queue()
-        self.pending_calls: Dict[CallID, asyncio.Future] = {}
+        self.pending_calls: Dict[CallID, asyncio.Future[bytes]] = {}
 
     @asynccontextmanager
     async def listen(self) -> AsyncIterator["ControlClient"]:

hivemind/proto/p2pd.proto

@@ -159,7 +159,6 @@ message PSRequest {
   optional bytes data = 3;
 }
 
-
 message PSMessage {
   optional bytes from_id = 1;
   optional bytes data = 2;