a2a.client.transports package

Submodules

a2a.client.transports.base module

class a2a.client.transports.base.ClientTransport

Bases: ABC

Abstract base class for a client transport.

abstractmethod async cancel_task(request: TaskIdParams, *, context: ClientCallContext | None = None) → Task

Requests the agent to cancel a specific task.

abstractmethod async close() → None

Closes the transport.

abstractmethod async get_card(*, context: ClientCallContext | None = None) → AgentCard

Retrieves the AgentCard.

abstractmethod async get_task(request: TaskQueryParams, *, context: ClientCallContext | None = None) → Task

Retrieves the current state and history of a specific task.

abstractmethod async get_task_callback(request: GetTaskPushNotificationConfigParams, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Retrieves the push notification configuration for a specific task.

abstractmethod async resubscribe(request: TaskIdParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | Message | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Reconnects to get task updates.

abstractmethod async send_message(request: MessageSendParams, *, context: ClientCallContext | None = None) → Task | Message

Sends a non-streaming message request to the agent.

abstractmethod async send_message_streaming(request: MessageSendParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Message | Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Sends a streaming message request to the agent and yields responses as they arrive.

abstractmethod async set_task_callback(request: TaskPushNotificationConfig, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Sets or updates the push notification configuration for a specific task.

a2a.client.transports.grpc module

class a2a.client.transports.grpc.GrpcTransport(channel: Channel, agent_card: AgentCard | None)

Bases: ClientTransport

A gRPC transport for the A2A client.

async cancel_task(request: TaskIdParams, *, context: ClientCallContext | None = None) → Task

Requests the agent to cancel a specific task.

async close() → None

Closes the gRPC channel.

classmethod create(card: AgentCard, url: str, config: ClientConfig, interceptors: list[ClientCallInterceptor]) → GrpcTransport

Creates a gRPC transport for the A2A client.

async get_card(*, context: ClientCallContext | None = None) → AgentCard

Retrieves the agent’s card.

async get_task(request: TaskQueryParams, *, context: ClientCallContext | None = None) → Task

Retrieves the current state and history of a specific task.

async get_task_callback(request: GetTaskPushNotificationConfigParams, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Retrieves the push notification configuration for a specific task.

resubscribe(request: TaskIdParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | Message | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Reconnects to get task updates.

async send_message(request: MessageSendParams, *, context: ClientCallContext | None = None) → Task | Message

Sends a non-streaming message request to the agent.

send_message_streaming(request: MessageSendParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Message | Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Sends a streaming message request to the agent and yields responses as they arrive.

async set_task_callback(request: TaskPushNotificationConfig, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Sets or updates the push notification configuration for a specific task.

a2a.client.transports.jsonrpc module

class a2a.client.transports.jsonrpc.JsonRpcTransport(httpx_client: AsyncClient, agent_card: AgentCard | None = None, url: str | None = None, interceptors: list[ClientCallInterceptor] | None = None)

Bases: ClientTransport

A JSON-RPC transport for the A2A client.

async cancel_task(request: TaskIdParams, *, context: ClientCallContext | None = None) → Task

Requests the agent to cancel a specific task.

async close() → None

Closes the httpx client.

async get_card(*, context: ClientCallContext | None = None) → AgentCard

Retrieves the agent’s card.

async get_task(request: TaskQueryParams, *, context: ClientCallContext | None = None) → Task

Retrieves the current state and history of a specific task.

async get_task_callback(request: GetTaskPushNotificationConfigParams, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Retrieves the push notification configuration for a specific task.

resubscribe(request: TaskIdParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | Message | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Reconnects to get task updates.

async send_message(request: MessageSendParams, *, context: ClientCallContext | None = None) → Task | Message

Sends a non-streaming message request to the agent.

send_message_streaming(request: MessageSendParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Message | Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Sends a streaming message request to the agent and yields responses as they arrive.

async set_task_callback(request: TaskPushNotificationConfig, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Sets or updates the push notification configuration for a specific task.

a2a.client.transports.rest module

class a2a.client.transports.rest.RestTransport(httpx_client: AsyncClient, agent_card: AgentCard | None = None, url: str | None = None, interceptors: list[ClientCallInterceptor] | None = None)

Bases: ClientTransport

A REST transport for the A2A client.

async cancel_task(request: TaskIdParams, *, context: ClientCallContext | None = None) → Task

Requests the agent to cancel a specific task.

async close() → None

Closes the httpx client.

async get_card(*, context: ClientCallContext | None = None) → AgentCard

Retrieves the agent’s card.

async get_task(request: TaskQueryParams, *, context: ClientCallContext | None = None) → Task

Retrieves the current state and history of a specific task.

async get_task_callback(request: GetTaskPushNotificationConfigParams, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Retrieves the push notification configuration for a specific task.

resubscribe(request: TaskIdParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent | Message]

Reconnects to get task updates.

async send_message(request: MessageSendParams, *, context: ClientCallContext | None = None) → Task | Message

Sends a non-streaming message request to the agent.

send_message_streaming(request: MessageSendParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent | Message]

Sends a streaming message request to the agent and yields responses as they arrive.

async set_task_callback(request: TaskPushNotificationConfig, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Sets or updates the push notification configuration for a specific task.

Module contents

A2A Client Transports.

class a2a.client.transports.ClientTransport

Bases: ABC

Abstract base class for a client transport.

abstractmethod async cancel_task(request: TaskIdParams, *, context: ClientCallContext | None = None) → Task

Requests the agent to cancel a specific task.

abstractmethod async close() → None

Closes the transport.

abstractmethod async get_card(*, context: ClientCallContext | None = None) → AgentCard

Retrieves the AgentCard.

abstractmethod async get_task(request: TaskQueryParams, *, context: ClientCallContext | None = None) → Task

Retrieves the current state and history of a specific task.

abstractmethod async get_task_callback(request: GetTaskPushNotificationConfigParams, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Retrieves the push notification configuration for a specific task.

abstractmethod async resubscribe(request: TaskIdParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | Message | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Reconnects to get task updates.

abstractmethod async send_message(request: MessageSendParams, *, context: ClientCallContext | None = None) → Task | Message

Sends a non-streaming message request to the agent.

abstractmethod async send_message_streaming(request: MessageSendParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Message | Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Sends a streaming message request to the agent and yields responses as they arrive.

abstractmethod async set_task_callback(request: TaskPushNotificationConfig, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Sets or updates the push notification configuration for a specific task.

class a2a.client.transports.GrpcTransport(channel: Channel, agent_card: AgentCard | None)

Bases: ClientTransport

A gRPC transport for the A2A client.

async cancel_task(request: TaskIdParams, *, context: ClientCallContext | None = None) → Task

Requests the agent to cancel a specific task.

async close() → None

Closes the gRPC channel.

classmethod create(card: AgentCard, url: str, config: ClientConfig, interceptors: list[ClientCallInterceptor]) → GrpcTransport

Creates a gRPC transport for the A2A client.

async get_card(*, context: ClientCallContext | None = None) → AgentCard

Retrieves the agent’s card.

async get_task(request: TaskQueryParams, *, context: ClientCallContext | None = None) → Task

Retrieves the current state and history of a specific task.

async get_task_callback(request: GetTaskPushNotificationConfigParams, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Retrieves the push notification configuration for a specific task.

resubscribe(request: TaskIdParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | Message | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Reconnects to get task updates.

async send_message(request: MessageSendParams, *, context: ClientCallContext | None = None) → Task | Message

Sends a non-streaming message request to the agent.

send_message_streaming(request: MessageSendParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Message | Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Sends a streaming message request to the agent and yields responses as they arrive.

async set_task_callback(request: TaskPushNotificationConfig, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Sets or updates the push notification configuration for a specific task.

class a2a.client.transports.JsonRpcTransport(httpx_client: AsyncClient, agent_card: AgentCard | None = None, url: str | None = None, interceptors: list[ClientCallInterceptor] | None = None)

Bases: ClientTransport

A JSON-RPC transport for the A2A client.

async cancel_task(request: TaskIdParams, *, context: ClientCallContext | None = None) → Task

Requests the agent to cancel a specific task.

async close() → None

Closes the httpx client.

async get_card(*, context: ClientCallContext | None = None) → AgentCard

Retrieves the agent’s card.

async get_task(request: TaskQueryParams, *, context: ClientCallContext | None = None) → Task

Retrieves the current state and history of a specific task.

async get_task_callback(request: GetTaskPushNotificationConfigParams, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Retrieves the push notification configuration for a specific task.

resubscribe(request: TaskIdParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | Message | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Reconnects to get task updates.

async send_message(request: MessageSendParams, *, context: ClientCallContext | None = None) → Task | Message

Sends a non-streaming message request to the agent.

send_message_streaming(request: MessageSendParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Message | Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent]

Sends a streaming message request to the agent and yields responses as they arrive.

async set_task_callback(request: TaskPushNotificationConfig, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Sets or updates the push notification configuration for a specific task.

class a2a.client.transports.RestTransport(httpx_client: AsyncClient, agent_card: AgentCard | None = None, url: str | None = None, interceptors: list[ClientCallInterceptor] | None = None)

Bases: ClientTransport

A REST transport for the A2A client.

async cancel_task(request: TaskIdParams, *, context: ClientCallContext | None = None) → Task

Requests the agent to cancel a specific task.

async close() → None

Closes the httpx client.

async get_card(*, context: ClientCallContext | None = None) → AgentCard

Retrieves the agent’s card.

async get_task(request: TaskQueryParams, *, context: ClientCallContext | None = None) → Task

Retrieves the current state and history of a specific task.

async get_task_callback(request: GetTaskPushNotificationConfigParams, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Retrieves the push notification configuration for a specific task.

resubscribe(request: TaskIdParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent | Message]

Reconnects to get task updates.

async send_message(request: MessageSendParams, *, context: ClientCallContext | None = None) → Task | Message

Sends a non-streaming message request to the agent.

send_message_streaming(request: MessageSendParams, *, context: ClientCallContext | None = None) → AsyncGenerator[Task | TaskStatusUpdateEvent | TaskArtifactUpdateEvent | Message]

Sends a streaming message request to the agent and yields responses as they arrive.

async set_task_callback(request: TaskPushNotificationConfig, *, context: ClientCallContext | None = None) → TaskPushNotificationConfig

Sets or updates the push notification configuration for a specific task.