Skip to content

Feature Request: Add gRPC & Async-Queue AgentTool for Issue Analyzer #11

Description

@Shreyanand

Why

We need anAgentTool that lets other AutoGen agents call Issue Analyzer team over gRPC.
After the sync path lands, we’ll add an async path that publishes requests to a queue and lets Issue Analyzer consume them at its own pace.


Deliverables (chronological)

  1. Define protobuf

    • team.proto with Handle(Query) → Reply RPC and streaming support (stream Reply HandleStream(stream Query)).
  2. Generate Python stubs

    • Use python -m grpc_tools.protoc ….
  3. Implement sync IssueAnalyzerTool

    # tools/team_a_grpc.py
    import grpc
    from proto.team_pb2_grpc import TeamServiceStub
    from proto.team_pb2       import Query
    from autogen_agentchat.tools import AgentTool
    
    class TeamATool(AgentTool):
        name        = "team_a"
        description = "Delegates work to Team A over gRPC"
    
        def _run(self, prompt: str, **_) -> str:
            with grpc.insecure_channel("team-a.agents.svc.cluster.local:50051") as ch:
                ans = TeamServiceStub(ch).Handle(Query(prompt=prompt), timeout=30)
                return ans.answer
  4. Implement async IssueAnalyzerTool
    ...

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions