Skip to content

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

@Shreyanand

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
No fields configured for issues without a type.

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions