HTTPAgentBus(agents=(), *, long_polling_interval=10.0, additional_services=())
Create HTTPAgentBus runtime.
Makes the passed agents capable of processing remote calls.
| PARAMETER | DESCRIPTION |
agents | Agents to register as remote services. TYPE: Iterable[ConversableAgent] DEFAULT: () |
long_polling_interval | Timeout to respond on task status calls for long-living executions. Should be less than clients' HTTP request timeout. TYPE: float DEFAULT: 10.0 |
additional_services | Additional services to register. TYPE: Iterable[RemoteService] DEFAULT: () |
Source code in autogen/remote/runtime.py
| def __init__(
self,
agents: Iterable[ConversableAgent] = (),
*,
long_polling_interval: float = 10.0,
additional_services: Iterable[RemoteService] = (),
) -> None:
"""Create HTTPAgentBus runtime.
Makes the passed agents capable of processing remote calls.
Args:
agents: Agents to register as remote services.
long_polling_interval: Timeout to respond on task status calls for long-living executions.
Should be less than clients' HTTP request timeout.
additional_services: Additional services to register.
"""
self.app = FastAPI()
for service in chain(map(AgentService, agents), additional_services):
register_agent_endpoints(
app=self.app,
service=service,
long_polling_interval=long_polling_interval,
)
|