Skip to content

Commit

Permalink
format again
Browse files Browse the repository at this point in the history
  • Loading branch information
rysweet committed Dec 3, 2024
1 parent 3b896e9 commit 90fa13e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
thisdir = os.path.dirname(os.path.abspath(__file__))
sys.path.append(os.path.join(thisdir, "..", ".."))
from dotenv import load_dotenv
from protos.agent_events_pb2 import NewMessageReceived, Output # type: ignore
from protos.agent_events_pb2 import NewMessageReceived, Output # type: ignore
from user_input import UserProxy

agnext_logger = logging.getLogger("autogen_core")
Expand Down Expand Up @@ -46,7 +46,7 @@ async def main() -> None:

new_message = NewMessageReceived(message="from Python!")
output_message = Output(message="^v^v^v---Wild Hello from Python!---^v^v^v")

await runtime.publish_message(
message=new_message,
topic_id=DefaultTopicId("agents.NewMessageReceived", "HelloAgents/python"),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -733,7 +733,7 @@ async def factory_wrapper() -> T:

async def _process_register_agent_type_response(self, response: agent_worker_pb2.RegisterAgentTypeResponse) -> None:
future = self._pending_requests.pop(response.request_id)
if response.HasField("error") and response.error != "":
if response.HasField("error") and response.error != "":
future.set_exception(RuntimeError(response.error))
else:
future.set_result(None)
Expand Down

0 comments on commit 90fa13e

Please sign in to comment.