Skip to main content
Remote agent implementation for executing agents via API.

RemoteAgent

from mcp_use.agents.remote import RemoteAgent

method init

Initialize remote agent.Parameters
agent_id
str
required
The ID of the remote agent to execute
chat_id
str | None
default:"None"
The ID of the chat session to use. If None, a new chat session will be created.
api_key
str | None
default:"None"
API key for authentication. If None, will check MCP_USE_API_KEY env var
base_url
str
default:"https://cloud.mcp-use.com"
Base URL for the remote API
Signature
def __init__(agent_id: str, chat_id: str | None = None, api_key: str | None = None, base_url: str = "https://cloud.mcp-use.com"):

method close

Close the HTTP client.Signature
def close():

method run

Executes the agent and returns the final result. This method uses HTTP streaming to avoid timeouts for long-running tasks. It consumes the entire stream and returns only the final result.Parameters
query
str
required
Query string or input
max_steps
int | None
default:"None"
Integer value
external_history
list[langchain_core.messages.base.BaseMessage] | None
default:"None"
List of items
output_schema
type[~T] | None
default:"None"
Parameter value
Returns
returns
str | mcp_use.agents.remote.T
Signature
def run(
query: str,
    max_steps: int | None = None,
    external_history: list[langchain_core.messages.base.BaseMessage] | None = None,
    output_schema: type[~T] | None = None
):

method stream

Stream the execution of a query on the remote agent using HTTP streaming.Parameters
query
str
required
Query string or input
max_steps
int | None
default:"None"
Integer value
external_history
list[langchain_core.messages.base.BaseMessage] | None
default:"None"
List of items
output_schema
type[~T] | None
default:"None"
Parameter value
Returns
returns
AsyncGenerator
Signature
def stream(
query: str,
    max_steps: int | None = None,
    external_history: list[langchain_core.messages.base.BaseMessage] | None = None,
    output_schema: type[~T] | None = None
):