Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
306 changes: 92 additions & 214 deletions src/llama_stack_client/_client.py

Large diffs are not rendered by default.

17 changes: 17 additions & 0 deletions src/llama_stack_client/_wrappers.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.

from typing import Generic, TypeVar

from ._models import GenericModel

__all__ = ["DataWrapper"]

_T = TypeVar("_T")


class DataWrapper(GenericModel, Generic[_T]):
data: _T

@staticmethod
def _unwrapper(obj: "DataWrapper[_T]") -> _T:
return obj.data
19 changes: 14 additions & 5 deletions src/llama_stack_client/resources/datasets.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

from __future__ import annotations

from typing import Dict, Union, Iterable, Optional
from typing import Dict, Type, Union, Iterable, Optional, cast

import httpx

Expand All @@ -21,6 +21,7 @@
async_to_raw_response_wrapper,
async_to_streamed_response_wrapper,
)
from .._wrappers import DataWrapper
from .._base_client import make_request_options
from ..types.shared_params.url import URL
from ..types.dataset_list_response import DatasetListResponse
Expand Down Expand Up @@ -126,9 +127,13 @@ def list(
return self._get(
"/v1/datasets",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[DatasetListResponse]._unwrapper,
),
cast_to=DatasetListResponse,
cast_to=cast(Type[DatasetListResponse], DataWrapper[DatasetListResponse]),
)

def register(
Expand Down Expand Up @@ -328,9 +333,13 @@ async def list(
return await self._get(
"/v1/datasets",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[DatasetListResponse]._unwrapper,
),
cast_to=DatasetListResponse,
cast_to=cast(Type[DatasetListResponse], DataWrapper[DatasetListResponse]),
)

async def register(
Expand Down
19 changes: 14 additions & 5 deletions src/llama_stack_client/resources/eval_tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

from __future__ import annotations

from typing import Dict, List, Union, Iterable, Optional
from typing import Dict, List, Type, Union, Iterable, Optional, cast

import httpx

Expand All @@ -21,6 +21,7 @@
async_to_raw_response_wrapper,
async_to_streamed_response_wrapper,
)
from .._wrappers import DataWrapper
from .._base_client import make_request_options
from ..types.eval_task import EvalTask
from ..types.eval_task_list_response import EvalTaskListResponse
Expand Down Expand Up @@ -124,9 +125,13 @@ def list(
return self._get(
"/v1/eval-tasks",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[EvalTaskListResponse]._unwrapper,
),
cast_to=EvalTaskListResponse,
cast_to=cast(Type[EvalTaskListResponse], DataWrapper[EvalTaskListResponse]),
)

def register(
Expand Down Expand Up @@ -283,9 +288,13 @@ async def list(
return await self._get(
"/v1/eval-tasks",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[EvalTaskListResponse]._unwrapper,
),
cast_to=EvalTaskListResponse,
cast_to=cast(Type[EvalTaskListResponse], DataWrapper[EvalTaskListResponse]),
)

async def register(
Expand Down
19 changes: 14 additions & 5 deletions src/llama_stack_client/resources/memory_banks.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

from __future__ import annotations

from typing import Any, Optional, cast
from typing import Any, Type, Optional, cast

import httpx

Expand All @@ -21,6 +21,7 @@
async_to_raw_response_wrapper,
async_to_streamed_response_wrapper,
)
from .._wrappers import DataWrapper
from .._base_client import make_request_options
from ..types.memory_bank_list_response import MemoryBankListResponse
from ..types.memory_bank_register_response import MemoryBankRegisterResponse
Expand Down Expand Up @@ -130,9 +131,13 @@ def list(
return self._get(
"/v1/memory-banks",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[MemoryBankListResponse]._unwrapper,
),
cast_to=MemoryBankListResponse,
cast_to=cast(Type[MemoryBankListResponse], DataWrapper[MemoryBankListResponse]),
)

def register(
Expand Down Expand Up @@ -337,9 +342,13 @@ async def list(
return await self._get(
"/v1/memory-banks",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[MemoryBankListResponse]._unwrapper,
),
cast_to=MemoryBankListResponse,
cast_to=cast(Type[MemoryBankListResponse], DataWrapper[MemoryBankListResponse]),
)

async def register(
Expand Down
19 changes: 14 additions & 5 deletions src/llama_stack_client/resources/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

from __future__ import annotations

from typing import Dict, Union, Iterable, Optional
from typing import Dict, Type, Union, Iterable, Optional, cast
from typing_extensions import Literal

import httpx
Expand All @@ -22,6 +22,7 @@
async_to_raw_response_wrapper,
async_to_streamed_response_wrapper,
)
from .._wrappers import DataWrapper
from ..types.model import Model
from .._base_client import make_request_options
from ..types.model_list_response import ModelListResponse
Expand Down Expand Up @@ -125,9 +126,13 @@ def list(
return self._get(
"/v1/models",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[ModelListResponse]._unwrapper,
),
cast_to=ModelListResponse,
cast_to=cast(Type[ModelListResponse], DataWrapper[ModelListResponse]),
)

def register(
Expand Down Expand Up @@ -324,9 +329,13 @@ async def list(
return await self._get(
"/v1/models",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[ModelListResponse]._unwrapper,
),
cast_to=ModelListResponse,
cast_to=cast(Type[ModelListResponse], DataWrapper[ModelListResponse]),
)

async def register(
Expand Down
19 changes: 14 additions & 5 deletions src/llama_stack_client/resources/post_training/job.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

from __future__ import annotations

from typing import Optional
from typing import Type, Optional, cast

import httpx

Expand All @@ -20,6 +20,7 @@
async_to_raw_response_wrapper,
async_to_streamed_response_wrapper,
)
from ..._wrappers import DataWrapper
from ..._base_client import make_request_options
from ...types.post_training import job_cancel_params, job_status_params, job_artifacts_params
from ...types.post_training.job_list_response import JobListResponse
Expand Down Expand Up @@ -83,9 +84,13 @@ def list(
return self._get(
"/v1/post-training/jobs",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[JobListResponse]._unwrapper,
),
cast_to=JobListResponse,
cast_to=cast(Type[JobListResponse], DataWrapper[JobListResponse]),
)

def artifacts(
Expand Down Expand Up @@ -273,9 +278,13 @@ async def list(
return await self._get(
"/v1/post-training/jobs",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[JobListResponse]._unwrapper,
),
cast_to=JobListResponse,
cast_to=cast(Type[JobListResponse], DataWrapper[JobListResponse]),
)

async def artifacts(
Expand Down
19 changes: 15 additions & 4 deletions src/llama_stack_client/resources/providers.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,8 @@

from __future__ import annotations

from typing import Type, cast

import httpx

from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
Expand All @@ -14,6 +16,7 @@
async_to_raw_response_wrapper,
async_to_streamed_response_wrapper,
)
from .._wrappers import DataWrapper
from .._base_client import make_request_options
from ..types.provider_list_response import ProviderListResponse

Expand Down Expand Up @@ -74,9 +77,13 @@ def list(
return self._get(
"/v1/providers/list",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[ProviderListResponse]._unwrapper,
),
cast_to=ProviderListResponse,
cast_to=cast(Type[ProviderListResponse], DataWrapper[ProviderListResponse]),
)


Expand Down Expand Up @@ -134,9 +141,13 @@ async def list(
return await self._get(
"/v1/providers/list",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[ProviderListResponse]._unwrapper,
),
cast_to=ProviderListResponse,
cast_to=cast(Type[ProviderListResponse], DataWrapper[ProviderListResponse]),
)


Expand Down
19 changes: 14 additions & 5 deletions src/llama_stack_client/resources/scoring_functions.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

from __future__ import annotations

from typing import Optional
from typing import Type, Optional, cast

import httpx

Expand All @@ -21,6 +21,7 @@
async_to_raw_response_wrapper,
async_to_streamed_response_wrapper,
)
from .._wrappers import DataWrapper
from .._base_client import make_request_options
from ..types.scoring_fn import ScoringFn
from ..types.shared_params.return_type import ReturnType
Expand Down Expand Up @@ -125,9 +126,13 @@ def list(
return self._get(
"/v1/scoring-functions",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[ScoringFunctionListResponse]._unwrapper,
),
cast_to=ScoringFunctionListResponse,
cast_to=cast(Type[ScoringFunctionListResponse], DataWrapper[ScoringFunctionListResponse]),
)

def register(
Expand Down Expand Up @@ -284,9 +289,13 @@ async def list(
return await self._get(
"/v1/scoring-functions",
options=make_request_options(
extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
extra_headers=extra_headers,
extra_query=extra_query,
extra_body=extra_body,
timeout=timeout,
post_parser=DataWrapper[ScoringFunctionListResponse]._unwrapper,
),
cast_to=ScoringFunctionListResponse,
cast_to=cast(Type[ScoringFunctionListResponse], DataWrapper[ScoringFunctionListResponse]),
)

async def register(
Expand Down
Loading
Loading