From 76da508ddf4b84dec01833233d713727cfbc276c Mon Sep 17 00:00:00 2001 From: Jack Gerrits Date: Fri, 7 Feb 2025 08:49:51 -0500 Subject: [PATCH] fmt, etc --- .../runtimes/grpc/_worker_runtime_host_servicer.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/python/packages/autogen-ext/src/autogen_ext/runtimes/grpc/_worker_runtime_host_servicer.py b/python/packages/autogen-ext/src/autogen_ext/runtimes/grpc/_worker_runtime_host_servicer.py index e2c4bd633dfb..621ed9511eb4 100644 --- a/python/packages/autogen-ext/src/autogen_ext/runtimes/grpc/_worker_runtime_host_servicer.py +++ b/python/packages/autogen-ext/src/autogen_ext/runtimes/grpc/_worker_runtime_host_servicer.py @@ -202,17 +202,19 @@ async def _receive_message(self, client_id: ClientConnectionId, message: agent_w case None: logger.warning("Received empty message") - async def _receive_control_message(self, client_id: ClientConnectionId, message: agent_worker_pb2.ControlMessage) -> None: + async def _receive_control_message( + self, client_id: ClientConnectionId, message: agent_worker_pb2.ControlMessage + ) -> None: logger.info(f"Received message from client {client_id}: {message}") destination = message.destination if destination.startswith("agentid="): - agent_id = AgentId.from_str(destination[len("agentid="):]) + agent_id = AgentId.from_str(destination[len("agentid=") :]) target_client_id = self._agent_type_to_client_id.get(agent_id.type) if target_client_id is None: logger.error(f"Agent client id not found for agent type {agent_id.type}.") return elif destination.startswith("clientid="): - target_client_id = destination[len("clientid="):] + target_client_id = destination[len("clientid=") :] else: logger.error(f"Invalid destination {destination}") return