Skip to content

Refactor: Rename "agent" domain to "operator" across client SDK #118

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
jfrench9 merged 1 commit into from
May 17, 2026
Merged

Refactor: Rename "agent" domain to "operator" across client SDK #118

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 8 additions & 8 deletions robosystems_client/api/extensions_robo_ledger/op_auto_map_elements.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -121,9 +121,9 @@ def sync_detailed(
Args:
graph_id (str):
idempotency_key (None | str | Unset):
body (AutoMapElementsOperation): Run the MappingAgent over a mapping structure (async).
body (AutoMapElementsOperation): Run the MappingOperator over a mapping structure (async).

The MappingAgent walks every unmapped CoA element and proposes
The MappingOperator walks every unmapped CoA element and proposes
associations to reporting concepts. Confidence thresholds: ≥0.90
auto-approved (association created), 0.70-0.89 flagged for review
(created with `confidence` set; surface it in your UI), <0.70 skipped.
Expand Down Expand Up @@ -170,9 +170,9 @@ def sync(
Args:
graph_id (str):
idempotency_key (None | str | Unset):
body (AutoMapElementsOperation): Run the MappingAgent over a mapping structure (async).
body (AutoMapElementsOperation): Run the MappingOperator over a mapping structure (async).

The MappingAgent walks every unmapped CoA element and proposes
The MappingOperator walks every unmapped CoA element and proposes
associations to reporting concepts. Confidence thresholds: ≥0.90
auto-approved (association created), 0.70-0.89 flagged for review
(created with `confidence` set; surface it in your UI), <0.70 skipped.
Expand Down Expand Up @@ -214,9 +214,9 @@ async def asyncio_detailed(
Args:
graph_id (str):
idempotency_key (None | str | Unset):
body (AutoMapElementsOperation): Run the MappingAgent over a mapping structure (async).
body (AutoMapElementsOperation): Run the MappingOperator over a mapping structure (async).

The MappingAgent walks every unmapped CoA element and proposes
The MappingOperator walks every unmapped CoA element and proposes
associations to reporting concepts. Confidence thresholds: ≥0.90
auto-approved (association created), 0.70-0.89 flagged for review
(created with `confidence` set; surface it in your UI), <0.70 skipped.
Expand Down Expand Up @@ -261,9 +261,9 @@ async def asyncio(
Args:
graph_id (str):
idempotency_key (None | str | Unset):
body (AutoMapElementsOperation): Run the MappingAgent over a mapping structure (async).
body (AutoMapElementsOperation): Run the MappingOperator over a mapping structure (async).

The MappingAgent walks every unmapped CoA element and proposes
The MappingOperator walks every unmapped CoA element and proposes
associations to reporting concepts. Confidence thresholds: ≥0.90
auto-approved (association created), 0.70-0.89 flagged for review
(created with `confidence` set; surface it in your UI), <0.70 skipped.
Expand Down
8 changes: 4 additions & 4 deletions robosystems_client/api/extensions_robo_ledger/op_create_mapping_association.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,7 @@ def sync_detailed(

This is the iterative, AI-assisted craft path. Each call adds a single
association to the target mapping structure. Use `auto-map-elements`
to create many at once via the MappingAgent. Reject duplicates: if
to create many at once via the MappingOperator. Reject duplicates: if
the (from, to, type) tuple already exists, the call returns 409.

Raises:
Expand Down Expand Up @@ -174,7 +174,7 @@ def sync(

This is the iterative, AI-assisted craft path. Each call adds a single
association to the target mapping structure. Use `auto-map-elements`
to create many at once via the MappingAgent. Reject duplicates: if
to create many at once via the MappingOperator. Reject duplicates: if
the (from, to, type) tuple already exists, the call returns 409.

Raises:
Expand Down Expand Up @@ -215,7 +215,7 @@ async def asyncio_detailed(

This is the iterative, AI-assisted craft path. Each call adds a single
association to the target mapping structure. Use `auto-map-elements`
to create many at once via the MappingAgent. Reject duplicates: if
to create many at once via the MappingOperator. Reject duplicates: if
the (from, to, type) tuple already exists, the call returns 409.

Raises:
Expand Down Expand Up @@ -259,7 +259,7 @@ async def asyncio(

This is the iterative, AI-assisted craft path. Each call adds a single
association to the target mapping structure. Use `auto-map-elements`
to create many at once via the MappingAgent. Reject duplicates: if
to create many at once via the MappingOperator. Reject duplicates: if
the (from, to, type) tuple already exists, the call returns 409.

Raises:
Expand Down
0 robosystems_client/api/agent/__init__.py → robosystems_client/api/operator/__init__.py
View file
Open in desktop
File renamed without changes.
70 changes: 35 additions & 35 deletions ...ems_client/api/agent/auto_select_agent.py → ...ient/api/operator/auto_select_operator.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,18 +6,18 @@

from ... import errors
from ...client import AuthenticatedClient, Client
from ...models.agent_request import AgentRequest
from ...models.agent_response import AgentResponse
from ...models.error_response import ErrorResponse
from ...models.http_validation_error import HTTPValidationError
from ...models.operator_request import OperatorRequest
from ...models.operator_response import OperatorResponse
from ...models.response_mode import ResponseMode
from ...types import UNSET, Response, Unset


def _get_kwargs(
graph_id: str,
*,
body: AgentRequest,
body: OperatorRequest,
mode: None | ResponseMode | Unset = UNSET,
) -> dict[str, Any]:
headers: dict[str, Any] = {}
Expand All @@ -37,7 +37,7 @@ def _get_kwargs(

_kwargs: dict[str, Any] = {
"method": "post",
"url": "/v1/graphs/{graph_id}/agent".format(
"url": "/v1/graphs/{graph_id}/operator".format(
graph_id=quote(str(graph_id), safe=""),
),
"params": params,
Expand All @@ -53,9 +53,9 @@ def _get_kwargs(

def _parse_response(
*, client: AuthenticatedClient | Client, response: httpx.Response
) -> AgentResponse | Any | ErrorResponse | HTTPValidationError | None:
) -> Any | ErrorResponse | HTTPValidationError | OperatorResponse | None:
if response.status_code == 200:
response_200 = AgentResponse.from_dict(response.json())
response_200 = OperatorResponse.from_dict(response.json())

return response_200

Expand Down Expand Up @@ -110,7 +110,7 @@ def _parse_response(

def _build_response(
*, client: AuthenticatedClient | Client, response: httpx.Response
) -> Response[AgentResponse | Any | ErrorResponse | HTTPValidationError]:
) -> Response[Any | ErrorResponse | HTTPValidationError | OperatorResponse]:
return Response(
status_code=HTTPStatus(response.status_code),
content=response.content,
Expand All @@ -123,27 +123,27 @@ def sync_detailed(
graph_id: str,
*,
client: AuthenticatedClient,
body: AgentRequest,
body: OperatorRequest,
mode: None | ResponseMode | Unset = UNSET,
) -> Response[AgentResponse | Any | ErrorResponse | HTTPValidationError]:
"""Auto-select Agent for Query
) -> Response[Any | ErrorResponse | HTTPValidationError | OperatorResponse]:
"""Auto-select Operator for Query

Routes to the best agent for your query. Agents: `financial` (SEC, accounting), `research` (deep
analysis), `rag` (knowledge base, free). Credit cost by mode: `quick` 5-10, `standard` 15-25,
Routes to the best operator for your query. Operators: `financial` (SEC, accounting), `research`
(deep analysis), `rag` (knowledge base, free). Credit cost by mode: `quick` 5-10, `standard` 15-25,
`extended` 30-75. Execution strategy (sync/SSE/async) auto-selected; override with
`?mode=sync|async`.

Args:
graph_id (str):
mode (None | ResponseMode | Unset): Override execution mode: sync, async, stream, or auto
body (AgentRequest): Request model for agent interactions.
body (OperatorRequest): Request model for operator interactions.

Raises:
errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True.
httpx.TimeoutException: If the request takes longer than Client.timeout.

Returns:
Response[AgentResponse | Any | ErrorResponse | HTTPValidationError]
Response[Any | ErrorResponse | HTTPValidationError | OperatorResponse]
"""

kwargs = _get_kwargs(
Expand All @@ -163,27 +163,27 @@ def sync(
graph_id: str,
*,
client: AuthenticatedClient,
body: AgentRequest,
body: OperatorRequest,
mode: None | ResponseMode | Unset = UNSET,
) -> AgentResponse | Any | ErrorResponse | HTTPValidationError | None:
"""Auto-select Agent for Query
) -> Any | ErrorResponse | HTTPValidationError | OperatorResponse | None:
"""Auto-select Operator for Query

Routes to the best agent for your query. Agents: `financial` (SEC, accounting), `research` (deep
analysis), `rag` (knowledge base, free). Credit cost by mode: `quick` 5-10, `standard` 15-25,
Routes to the best operator for your query. Operators: `financial` (SEC, accounting), `research`
(deep analysis), `rag` (knowledge base, free). Credit cost by mode: `quick` 5-10, `standard` 15-25,
`extended` 30-75. Execution strategy (sync/SSE/async) auto-selected; override with
`?mode=sync|async`.

Args:
graph_id (str):
mode (None | ResponseMode | Unset): Override execution mode: sync, async, stream, or auto
body (AgentRequest): Request model for agent interactions.
body (OperatorRequest): Request model for operator interactions.

Raises:
errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True.
httpx.TimeoutException: If the request takes longer than Client.timeout.

Returns:
AgentResponse | Any | ErrorResponse | HTTPValidationError
Any | ErrorResponse | HTTPValidationError | OperatorResponse
"""

return sync_detailed(
Expand All @@ -198,27 +198,27 @@ async def asyncio_detailed(
graph_id: str,
*,
client: AuthenticatedClient,
body: AgentRequest,
body: OperatorRequest,
mode: None | ResponseMode | Unset = UNSET,
) -> Response[AgentResponse | Any | ErrorResponse | HTTPValidationError]:
"""Auto-select Agent for Query
) -> Response[Any | ErrorResponse | HTTPValidationError | OperatorResponse]:
"""Auto-select Operator for Query

Routes to the best agent for your query. Agents: `financial` (SEC, accounting), `research` (deep
analysis), `rag` (knowledge base, free). Credit cost by mode: `quick` 5-10, `standard` 15-25,
Routes to the best operator for your query. Operators: `financial` (SEC, accounting), `research`
(deep analysis), `rag` (knowledge base, free). Credit cost by mode: `quick` 5-10, `standard` 15-25,
`extended` 30-75. Execution strategy (sync/SSE/async) auto-selected; override with
`?mode=sync|async`.

Args:
graph_id (str):
mode (None | ResponseMode | Unset): Override execution mode: sync, async, stream, or auto
body (AgentRequest): Request model for agent interactions.
body (OperatorRequest): Request model for operator interactions.

Raises:
errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True.
httpx.TimeoutException: If the request takes longer than Client.timeout.

Returns:
Response[AgentResponse | Any | ErrorResponse | HTTPValidationError]
Response[Any | ErrorResponse | HTTPValidationError | OperatorResponse]
"""

kwargs = _get_kwargs(
Expand All @@ -236,27 +236,27 @@ async def asyncio(
graph_id: str,
*,
client: AuthenticatedClient,
body: AgentRequest,
body: OperatorRequest,
mode: None | ResponseMode | Unset = UNSET,
) -> AgentResponse | Any | ErrorResponse | HTTPValidationError | None:
"""Auto-select Agent for Query
) -> Any | ErrorResponse | HTTPValidationError | OperatorResponse | None:
"""Auto-select Operator for Query

Routes to the best agent for your query. Agents: `financial` (SEC, accounting), `research` (deep
analysis), `rag` (knowledge base, free). Credit cost by mode: `quick` 5-10, `standard` 15-25,
Routes to the best operator for your query. Operators: `financial` (SEC, accounting), `research`
(deep analysis), `rag` (knowledge base, free). Credit cost by mode: `quick` 5-10, `standard` 15-25,
`extended` 30-75. Execution strategy (sync/SSE/async) auto-selected; override with
`?mode=sync|async`.

Args:
graph_id (str):
mode (None | ResponseMode | Unset): Override execution mode: sync, async, stream, or auto
body (AgentRequest): Request model for agent interactions.
body (OperatorRequest): Request model for operator interactions.

Raises:
errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True.
httpx.TimeoutException: If the request takes longer than Client.timeout.

Returns:
AgentResponse | Any | ErrorResponse | HTTPValidationError
Any | ErrorResponse | HTTPValidationError | OperatorResponse
"""

return (
Expand Down
Loading
Loading