Skip to content

Commit a8265ee

Browse files
jnapper7jnapper7
committed
fix: updated to latest 0.2.1 ACP spec.
1 parent 83f65f7 commit a8265ee

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

71 files changed

+972
-554
lines changed

‎acp-spec

‎agntcy_acp/acp_v0/__init__.py

+5-3
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
1010
No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
1111
12-
The version of the OpenAPI document: 0.2.0
12+
The version of the OpenAPI document: 0.2.1
1313
Generated by OpenAPI Generator (https://openapi-generator.tech)
1414
1515
Do not edit the class manually.
@@ -55,15 +55,17 @@
5555
from agntcy_acp.acp_v0.models.run_create import RunCreate
5656
from agntcy_acp.acp_v0.models.run_create_stateful import RunCreateStateful
5757
from agntcy_acp.acp_v0.models.run_create_stateless import RunCreateStateless
58-
from agntcy_acp.acp_v0.models.run_creation import RunCreation
5958
from agntcy_acp.acp_v0.models.run_error import RunError
6059
from agntcy_acp.acp_v0.models.run_interrupt import RunInterrupt
6160
from agntcy_acp.acp_v0.models.run_output import RunOutput
6261
from agntcy_acp.acp_v0.models.run_output_stream import RunOutputStream
6362
from agntcy_acp.acp_v0.models.run_result import RunResult
6463
from agntcy_acp.acp_v0.models.run_search_request import RunSearchRequest
64+
from agntcy_acp.acp_v0.models.run_stateful import RunStateful
65+
from agntcy_acp.acp_v0.models.run_stateless import RunStateless
6566
from agntcy_acp.acp_v0.models.run_status import RunStatus
66-
from agntcy_acp.acp_v0.models.run_wait_response import RunWaitResponse
67+
from agntcy_acp.acp_v0.models.run_wait_response_stateful import RunWaitResponseStateful
68+
from agntcy_acp.acp_v0.models.run_wait_response_stateless import RunWaitResponseStateless
6769
from agntcy_acp.acp_v0.models.stream_event_payload import StreamEventPayload
6870
from agntcy_acp.acp_v0.models.stream_mode import StreamMode
6971
from agntcy_acp.acp_v0.models.streaming_mode import StreamingMode

‎agntcy_acp/acp_v0/async_client/api/agents_api.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
88
No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
99
10-
The version of the OpenAPI document: 0.2.0
10+
The version of the OpenAPI document: 0.2.1
1111
Generated by OpenAPI Generator (https://openapi-generator.tech)
1212
1313
Do not edit the class manually.

‎agntcy_acp/acp_v0/async_client/api/stateless_runs_api.py

+33-33
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
88
No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
99
10-
The version of the OpenAPI document: 0.2.0
10+
The version of the OpenAPI document: 0.2.1
1111
Generated by OpenAPI Generator (https://openapi-generator.tech)
1212
1313
Do not edit the class manually.
@@ -21,11 +21,11 @@
2121
from pydantic import Field, StrictBool, StrictStr, field_validator
2222
from typing import Any, Dict, List, Optional
2323
from typing_extensions import Annotated
24-
from agntcy_acp.acp_v0.models.run import Run
2524
from agntcy_acp.acp_v0.models.run_create_stateless import RunCreateStateless
2625
from agntcy_acp.acp_v0.models.run_output_stream import RunOutputStream
2726
from agntcy_acp.acp_v0.models.run_search_request import RunSearchRequest
28-
from agntcy_acp.acp_v0.models.run_wait_response import RunWaitResponse
27+
from agntcy_acp.acp_v0.models.run_stateless import RunStateless
28+
from agntcy_acp.acp_v0.models.run_wait_response_stateless import RunWaitResponseStateless
2929

3030
from agntcy_acp.acp_v0.async_client.api_client import ApiClient, RequestSerialized
3131
from agntcy_acp.acp_v0.api_response import ApiResponse
@@ -641,7 +641,7 @@ async def create_and_wait_for_stateless_run_output(
641641
_content_type: Optional[StrictStr] = None,
642642
_headers: Optional[Dict[StrictStr, Any]] = None,
643643
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
644-
) -> RunWaitResponse:
644+
) -> RunWaitResponseStateless:
645645
"""Create a stateless run and wait for its output
646646
647647
Create a stateless run and wait for its output. See 'GET /runs/{run_id}/wait' for details on the return values.
@@ -679,7 +679,7 @@ async def create_and_wait_for_stateless_run_output(
679679
)
680680

681681
_response_types_map: Dict[str, Optional[str]] = {
682-
'200': "RunWaitResponse",
682+
'200': "RunWaitResponseStateless",
683683
'404': "str",
684684
'409': "str",
685685
'422': "str",
@@ -711,7 +711,7 @@ async def create_and_wait_for_stateless_run_output_with_http_info(
711711
_content_type: Optional[StrictStr] = None,
712712
_headers: Optional[Dict[StrictStr, Any]] = None,
713713
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
714-
) -> ApiResponse[RunWaitResponse]:
714+
) -> ApiResponse[RunWaitResponseStateless]:
715715
"""Create a stateless run and wait for its output
716716
717717
Create a stateless run and wait for its output. See 'GET /runs/{run_id}/wait' for details on the return values.
@@ -749,7 +749,7 @@ async def create_and_wait_for_stateless_run_output_with_http_info(
749749
)
750750

751751
_response_types_map: Dict[str, Optional[str]] = {
752-
'200': "RunWaitResponse",
752+
'200': "RunWaitResponseStateless",
753753
'404': "str",
754754
'409': "str",
755755
'422': "str",
@@ -819,7 +819,7 @@ async def create_and_wait_for_stateless_run_output_without_preload_content(
819819
)
820820

821821
_response_types_map: Dict[str, Optional[str]] = {
822-
'200': "RunWaitResponse",
822+
'200': "RunWaitResponseStateless",
823823
'404': "str",
824824
'409': "str",
825825
'422': "str",
@@ -923,7 +923,7 @@ async def create_stateless_run(
923923
_content_type: Optional[StrictStr] = None,
924924
_headers: Optional[Dict[StrictStr, Any]] = None,
925925
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
926-
) -> Run:
926+
) -> RunStateless:
927927
"""Create a Background stateless Run
928928
929929
Create a stateless run, return the run ID immediately. Don't wait for the final run output.
@@ -961,7 +961,7 @@ async def create_stateless_run(
961961
)
962962

963963
_response_types_map: Dict[str, Optional[str]] = {
964-
'200': "Run",
964+
'200': "RunStateless",
965965
'404': "str",
966966
'409': "str",
967967
'422': "str",
@@ -993,7 +993,7 @@ async def create_stateless_run_with_http_info(
993993
_content_type: Optional[StrictStr] = None,
994994
_headers: Optional[Dict[StrictStr, Any]] = None,
995995
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
996-
) -> ApiResponse[Run]:
996+
) -> ApiResponse[RunStateless]:
997997
"""Create a Background stateless Run
998998
999999
Create a stateless run, return the run ID immediately. Don't wait for the final run output.
@@ -1031,7 +1031,7 @@ async def create_stateless_run_with_http_info(
10311031
)
10321032

10331033
_response_types_map: Dict[str, Optional[str]] = {
1034-
'200': "Run",
1034+
'200': "RunStateless",
10351035
'404': "str",
10361036
'409': "str",
10371037
'422': "str",
@@ -1101,7 +1101,7 @@ async def create_stateless_run_without_preload_content(
11011101
)
11021102

11031103
_response_types_map: Dict[str, Optional[str]] = {
1104-
'200': "Run",
1104+
'200': "RunStateless",
11051105
'404': "str",
11061106
'409': "str",
11071107
'422': "str",
@@ -1471,7 +1471,7 @@ async def get_stateless_run(
14711471
_content_type: Optional[StrictStr] = None,
14721472
_headers: Optional[Dict[StrictStr, Any]] = None,
14731473
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
1474-
) -> Run:
1474+
) -> RunStateless:
14751475
"""Get Run
14761476
14771477
Get a stateless run by ID.
@@ -1509,7 +1509,7 @@ async def get_stateless_run(
15091509
)
15101510

15111511
_response_types_map: Dict[str, Optional[str]] = {
1512-
'200': "Run",
1512+
'200': "RunStateless",
15131513
'404': "str",
15141514
'422': "str",
15151515
}
@@ -1540,7 +1540,7 @@ async def get_stateless_run_with_http_info(
15401540
_content_type: Optional[StrictStr] = None,
15411541
_headers: Optional[Dict[StrictStr, Any]] = None,
15421542
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
1543-
) -> ApiResponse[Run]:
1543+
) -> ApiResponse[RunStateless]:
15441544
"""Get Run
15451545
15461546
Get a stateless run by ID.
@@ -1578,7 +1578,7 @@ async def get_stateless_run_with_http_info(
15781578
)
15791579

15801580
_response_types_map: Dict[str, Optional[str]] = {
1581-
'200': "Run",
1581+
'200': "RunStateless",
15821582
'404': "str",
15831583
'422': "str",
15841584
}
@@ -1647,7 +1647,7 @@ async def get_stateless_run_without_preload_content(
16471647
)
16481648

16491649
_response_types_map: Dict[str, Optional[str]] = {
1650-
'200': "Run",
1650+
'200': "RunStateless",
16511651
'404': "str",
16521652
'422': "str",
16531653
}
@@ -1738,7 +1738,7 @@ async def resume_stateless_run(
17381738
_content_type: Optional[StrictStr] = None,
17391739
_headers: Optional[Dict[StrictStr, Any]] = None,
17401740
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
1741-
) -> Run:
1741+
) -> RunStateless:
17421742
"""Resume an interrupted Run
17431743
17441744
Provide the needed input to a run to resume its execution. Can only be called for runs that are in the interrupted state Schema of the provided input must match with the schema specified in the agent specs under interrupts for the interrupt type the agent generated for this specific interruption.
@@ -1779,7 +1779,7 @@ async def resume_stateless_run(
17791779
)
17801780

17811781
_response_types_map: Dict[str, Optional[str]] = {
1782-
'200': "Run",
1782+
'200': "RunStateless",
17831783
'404': "str",
17841784
'409': "str",
17851785
'422': "str",
@@ -1812,7 +1812,7 @@ async def resume_stateless_run_with_http_info(
18121812
_content_type: Optional[StrictStr] = None,
18131813
_headers: Optional[Dict[StrictStr, Any]] = None,
18141814
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
1815-
) -> ApiResponse[Run]:
1815+
) -> ApiResponse[RunStateless]:
18161816
"""Resume an interrupted Run
18171817
18181818
Provide the needed input to a run to resume its execution. Can only be called for runs that are in the interrupted state Schema of the provided input must match with the schema specified in the agent specs under interrupts for the interrupt type the agent generated for this specific interruption.
@@ -1853,7 +1853,7 @@ async def resume_stateless_run_with_http_info(
18531853
)
18541854

18551855
_response_types_map: Dict[str, Optional[str]] = {
1856-
'200': "Run",
1856+
'200': "RunStateless",
18571857
'404': "str",
18581858
'409': "str",
18591859
'422': "str",
@@ -1927,7 +1927,7 @@ async def resume_stateless_run_without_preload_content(
19271927
)
19281928

19291929
_response_types_map: Dict[str, Optional[str]] = {
1930-
'200': "Run",
1930+
'200': "RunStateless",
19311931
'404': "str",
19321932
'409': "str",
19331933
'422': "str",
@@ -2034,7 +2034,7 @@ async def search_stateless_runs(
20342034
_content_type: Optional[StrictStr] = None,
20352035
_headers: Optional[Dict[StrictStr, Any]] = None,
20362036
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
2037-
) -> List[Run]:
2037+
) -> List[RunStateless]:
20382038
"""Search Stateless Runs
20392039
20402040
Search for stateless run. This endpoint also functions as the endpoint to list all stateless Runs.
@@ -2072,7 +2072,7 @@ async def search_stateless_runs(
20722072
)
20732073

20742074
_response_types_map: Dict[str, Optional[str]] = {
2075-
'200': "List[Run]",
2075+
'200': "List[RunStateless]",
20762076
'422': "str",
20772077
}
20782078
response_data = await self.api_client.call_api(
@@ -2102,7 +2102,7 @@ async def search_stateless_runs_with_http_info(
21022102
_content_type: Optional[StrictStr] = None,
21032103
_headers: Optional[Dict[StrictStr, Any]] = None,
21042104
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
2105-
) -> ApiResponse[List[Run]]:
2105+
) -> ApiResponse[List[RunStateless]]:
21062106
"""Search Stateless Runs
21072107
21082108
Search for stateless run. This endpoint also functions as the endpoint to list all stateless Runs.
@@ -2140,7 +2140,7 @@ async def search_stateless_runs_with_http_info(
21402140
)
21412141

21422142
_response_types_map: Dict[str, Optional[str]] = {
2143-
'200': "List[Run]",
2143+
'200': "List[RunStateless]",
21442144
'422': "str",
21452145
}
21462146
response_data = await self.api_client.call_api(
@@ -2208,7 +2208,7 @@ async def search_stateless_runs_without_preload_content(
22082208
)
22092209

22102210
_response_types_map: Dict[str, Optional[str]] = {
2211-
'200': "List[Run]",
2211+
'200': "List[RunStateless]",
22122212
'422': "str",
22132213
}
22142214
response_data = await self.api_client.call_api(
@@ -2577,7 +2577,7 @@ async def wait_for_stateless_run_output(
25772577
_content_type: Optional[StrictStr] = None,
25782578
_headers: Optional[Dict[StrictStr, Any]] = None,
25792579
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
2580-
) -> RunWaitResponse:
2580+
) -> RunWaitResponseStateless:
25812581
"""Blocks waiting for the result of the run.
25822582
25832583
Blocks waiting for the result of the run. The output can be: * an interrupt, this happens when the agent run status is `interrupted` * the final result of the run, this happens when the agent run status is `success` * an error, this happens when the agent run status is `error` or `timeout` This call blocks until the output is available.
@@ -2615,7 +2615,7 @@ async def wait_for_stateless_run_output(
26152615
)
26162616

26172617
_response_types_map: Dict[str, Optional[str]] = {
2618-
'200': "RunWaitResponse",
2618+
'200': "RunWaitResponseStateless",
26192619
'404': "str",
26202620
'422': "str",
26212621
}
@@ -2646,7 +2646,7 @@ async def wait_for_stateless_run_output_with_http_info(
26462646
_content_type: Optional[StrictStr] = None,
26472647
_headers: Optional[Dict[StrictStr, Any]] = None,
26482648
_host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
2649-
) -> ApiResponse[RunWaitResponse]:
2649+
) -> ApiResponse[RunWaitResponseStateless]:
26502650
"""Blocks waiting for the result of the run.
26512651
26522652
Blocks waiting for the result of the run. The output can be: * an interrupt, this happens when the agent run status is `interrupted` * the final result of the run, this happens when the agent run status is `success` * an error, this happens when the agent run status is `error` or `timeout` This call blocks until the output is available.
@@ -2684,7 +2684,7 @@ async def wait_for_stateless_run_output_with_http_info(
26842684
)
26852685

26862686
_response_types_map: Dict[str, Optional[str]] = {
2687-
'200': "RunWaitResponse",
2687+
'200': "RunWaitResponseStateless",
26882688
'404': "str",
26892689
'422': "str",
26902690
}
@@ -2753,7 +2753,7 @@ async def wait_for_stateless_run_output_without_preload_content(
27532753
)
27542754

27552755
_response_types_map: Dict[str, Optional[str]] = {
2756-
'200': "RunWaitResponse",
2756+
'200': "RunWaitResponseStateless",
27572757
'404': "str",
27582758
'422': "str",
27592759
}

0 commit comments

Comments
 (0)