feat: Cid/fetching endpoints

Author: stainless-app[bot]

.stats.yml

@@ -1,3 +1,3 @@
-configured_endpoints: 28
-openapi_spec_hash: 5f7962599290c70cb47c05c3b29fdbd8
-config_hash: f1c0c034bd832878eb47146c51afdd55
+configured_endpoints: 29
+openapi_spec_hash: 20caa671b1b1a87c0a5cb6ebd7e4b064
+config_hash: aaf12ae1da71c62ca5195fc2b66f657c

api.md

@@ -122,6 +122,7 @@ Types:
 from openlayer.types import (
     InferencePipelineRetrieveResponse,
     InferencePipelineUpdateResponse,
+    InferencePipelineRetrieveSessionsResponse,
     InferencePipelineRetrieveUsersResponse,
 )
 ```
@@ -131,7 +132,8 @@ Methods:
 - <code title="get /inference-pipelines/{inferencePipelineId}">client.inference_pipelines.<a href="./src/openlayer/resources/inference_pipelines/inference_pipelines.py">retrieve</a>(inference_pipeline_id, \*\*<a href="src/openlayer/types/inference_pipeline_retrieve_params.py">params</a>) -> <a href="./src/openlayer/types/inference_pipeline_retrieve_response.py">InferencePipelineRetrieveResponse</a></code>
 - <code title="put /inference-pipelines/{inferencePipelineId}">client.inference_pipelines.<a href="./src/openlayer/resources/inference_pipelines/inference_pipelines.py">update</a>(inference_pipeline_id, \*\*<a href="src/openlayer/types/inference_pipeline_update_params.py">params</a>) -> <a href="./src/openlayer/types/inference_pipeline_update_response.py">InferencePipelineUpdateResponse</a></code>
 - <code title="delete /inference-pipelines/{inferencePipelineId}">client.inference_pipelines.<a href="./src/openlayer/resources/inference_pipelines/inference_pipelines.py">delete</a>(inference_pipeline_id) -> None</code>
-- <code title="get /inference-pipelines/{inferencePipelineId}/users">client.inference_pipelines.<a href="./src/openlayer/resources/inference_pipelines/inference_pipelines.py">retrieve_users</a>(inference_pipeline_id, \*\*<a href="src/openlayer/types/inference_pipeline_retrieve_users_params.py">params</a>) -> <a href="./src/openlayer/types/inference_pipeline_retrieve_users_response.py">InferencePipelineRetrieveUsersResponse</a></code>
+- <code title="post /inference-pipelines/{inferencePipelineId}/sessions">client.inference_pipelines.<a href="./src/openlayer/resources/inference_pipelines/inference_pipelines.py">retrieve_sessions</a>(inference_pipeline_id, \*\*<a href="src/openlayer/types/inference_pipeline_retrieve_sessions_params.py">params</a>) -> <a href="./src/openlayer/types/inference_pipeline_retrieve_sessions_response.py">InferencePipelineRetrieveSessionsResponse</a></code>
+- <code title="post /inference-pipelines/{inferencePipelineId}/users">client.inference_pipelines.<a href="./src/openlayer/resources/inference_pipelines/inference_pipelines.py">retrieve_users</a>(inference_pipeline_id, \*\*<a href="src/openlayer/types/inference_pipeline_retrieve_users_params.py">params</a>) -> <a href="./src/openlayer/types/inference_pipeline_retrieve_users_response.py">InferencePipelineRetrieveUsersResponse</a></code>
 
 ## Data
 

src/openlayer/resources/inference_pipelines/inference_pipelines.py

@@ -24,3 +24,9 @@
 from .inference_pipeline_retrieve_users_response import (
     InferencePipelineRetrieveUsersResponse as InferencePipelineRetrieveUsersResponse,
 )
+from .inference_pipeline_retrieve_sessions_params import (
+    InferencePipelineRetrieveSessionsParams as InferencePipelineRetrieveSessionsParams,
+)
+from .inference_pipeline_retrieve_sessions_response import (
+    InferencePipelineRetrieveSessionsResponse as InferencePipelineRetrieveSessionsResponse,
+)

src/openlayer/types/__init__.py

@@ -0,0 +1,77 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from __future__ import annotations
+
+from typing import Union, Iterable, Optional
+from typing_extensions import Literal, Required, Annotated, TypeAlias, TypedDict
+
+from .._types import SequenceNotStr
+from .._utils import PropertyInfo
+
+__all__ = [
+    "InferencePipelineRetrieveSessionsParams",
+    "ColumnFilter",
+    "ColumnFilterSetColumnFilter",
+    "ColumnFilterNumericColumnFilter",
+    "ColumnFilterStringColumnFilter",
+]
+
+
+class InferencePipelineRetrieveSessionsParams(TypedDict, total=False):
+    asc: bool
+    """Whether or not to sort on the sortColumn in ascending order."""
+
+    page: int
+    """The page to return in a paginated query."""
+
+    per_page: Annotated[int, PropertyInfo(alias="perPage")]
+    """Maximum number of items to return per page."""
+
+    sort_column: Annotated[str, PropertyInfo(alias="sortColumn")]
+    """Name of the column to sort on"""
+
+    column_filters: Annotated[Optional[Iterable[ColumnFilter]], PropertyInfo(alias="columnFilters")]
+
+    exclude_row_id_list: Annotated[Optional[Iterable[int]], PropertyInfo(alias="excludeRowIdList")]
+
+    not_search_query_and: Annotated[Optional[SequenceNotStr[str]], PropertyInfo(alias="notSearchQueryAnd")]
+
+    not_search_query_or: Annotated[Optional[SequenceNotStr[str]], PropertyInfo(alias="notSearchQueryOr")]
+
+    row_id_list: Annotated[Optional[Iterable[int]], PropertyInfo(alias="rowIdList")]
+
+    search_query_and: Annotated[Optional[SequenceNotStr[str]], PropertyInfo(alias="searchQueryAnd")]
+
+    search_query_or: Annotated[Optional[SequenceNotStr[str]], PropertyInfo(alias="searchQueryOr")]
+
+
+class ColumnFilterSetColumnFilter(TypedDict, total=False):
+    measurement: Required[str]
+    """The name of the column."""
+
+    operator: Required[Literal["contains_none", "contains_any", "contains_all", "one_of", "none_of"]]
+
+    value: Required[SequenceNotStr[Union[str, float]]]
+
+
+class ColumnFilterNumericColumnFilter(TypedDict, total=False):
+    measurement: Required[str]
+    """The name of the column."""
+
+    operator: Required[Literal[">", ">=", "is", "<", "<=", "!="]]
+
+    value: Required[Optional[float]]
+
+
+class ColumnFilterStringColumnFilter(TypedDict, total=False):
+    measurement: Required[str]
+    """The name of the column."""
+
+    operator: Required[Literal["is", "!="]]
+
+    value: Required[Union[str, bool]]
+
+
+ColumnFilter: TypeAlias = Union[
+    ColumnFilterSetColumnFilter, ColumnFilterNumericColumnFilter, ColumnFilterStringColumnFilter
+]

src/openlayer/types/inference_pipeline_retrieve_sessions_params.py

@@ -0,0 +1,53 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from typing import Dict, List
+from datetime import datetime
+
+from pydantic import Field as FieldInfo
+
+from .._models import BaseModel
+
+__all__ = ["InferencePipelineRetrieveSessionsResponse", "Item"]
+
+
+class Item(BaseModel):
+    id: str
+    """The unique session identifier"""
+
+    cost: float
+    """Total cost for the session"""
+
+    date_created: datetime = FieldInfo(alias="dateCreated")
+    """Latest/most recent timestamp in the session"""
+
+    date_of_first_record: datetime = FieldInfo(alias="dateOfFirstRecord")
+    """Timestamp of the first request in the session"""
+
+    date_of_last_record: datetime = FieldInfo(alias="dateOfLastRecord")
+    """Timestamp of the last request in the session"""
+
+    duration: float
+    """Duration between first and last request (in milliseconds)"""
+
+    first_record: Dict[str, object] = FieldInfo(alias="firstRecord")
+    """The complete first record in the session"""
+
+    last_record: Dict[str, object] = FieldInfo(alias="lastRecord")
+    """The complete last record in the session"""
+
+    latency: float
+    """Total latency for the session (in milliseconds)"""
+
+    records: int
+    """Total number of records/traces in the session"""
+
+    tokens: float
+    """Total token count for the session"""
+
+    user_ids: List[str] = FieldInfo(alias="userIds")
+    """List of unique user IDs that participated in this session"""
+
+
+class InferencePipelineRetrieveSessionsResponse(BaseModel):
+    items: List[Item]
+    """Array of session aggregation data"""

src/openlayer/types/inference_pipeline_retrieve_sessions_response.py

@@ -2,16 +2,76 @@
 
 from __future__ import annotations
 
-from typing_extensions import Annotated, TypedDict
+from typing import Union, Iterable, Optional
+from typing_extensions import Literal, Required, Annotated, TypeAlias, TypedDict
 
+from .._types import SequenceNotStr
 from .._utils import PropertyInfo
 
-__all__ = ["InferencePipelineRetrieveUsersParams"]
+__all__ = [
+    "InferencePipelineRetrieveUsersParams",
+    "ColumnFilter",
+    "ColumnFilterSetColumnFilter",
+    "ColumnFilterNumericColumnFilter",
+    "ColumnFilterStringColumnFilter",
+]
 
 
 class InferencePipelineRetrieveUsersParams(TypedDict, total=False):
+    asc: bool
+    """Whether or not to sort on the sortColumn in ascending order."""
+
     page: int
     """The page to return in a paginated query."""
 
     per_page: Annotated[int, PropertyInfo(alias="perPage")]
     """Maximum number of items to return per page."""
+
+    sort_column: Annotated[str, PropertyInfo(alias="sortColumn")]
+    """Name of the column to sort on"""
+
+    column_filters: Annotated[Optional[Iterable[ColumnFilter]], PropertyInfo(alias="columnFilters")]
+
+    exclude_row_id_list: Annotated[Optional[Iterable[int]], PropertyInfo(alias="excludeRowIdList")]
+
+    not_search_query_and: Annotated[Optional[SequenceNotStr[str]], PropertyInfo(alias="notSearchQueryAnd")]
+
+    not_search_query_or: Annotated[Optional[SequenceNotStr[str]], PropertyInfo(alias="notSearchQueryOr")]
+
+    row_id_list: Annotated[Optional[Iterable[int]], PropertyInfo(alias="rowIdList")]
+
+    search_query_and: Annotated[Optional[SequenceNotStr[str]], PropertyInfo(alias="searchQueryAnd")]
+
+    search_query_or: Annotated[Optional[SequenceNotStr[str]], PropertyInfo(alias="searchQueryOr")]
+
+
+class ColumnFilterSetColumnFilter(TypedDict, total=False):
+    measurement: Required[str]
+    """The name of the column."""
+
+    operator: Required[Literal["contains_none", "contains_any", "contains_all", "one_of", "none_of"]]
+
+    value: Required[SequenceNotStr[Union[str, float]]]
+
+
+class ColumnFilterNumericColumnFilter(TypedDict, total=False):
+    measurement: Required[str]
+    """The name of the column."""
+
+    operator: Required[Literal[">", ">=", "is", "<", "<=", "!="]]
+
+    value: Required[Optional[float]]
+
+
+class ColumnFilterStringColumnFilter(TypedDict, total=False):
+    measurement: Required[str]
+    """The name of the column."""
+
+    operator: Required[Literal["is", "!="]]
+
+    value: Required[Union[str, bool]]
+
+
+ColumnFilter: TypeAlias = Union[
+    ColumnFilterSetColumnFilter, ColumnFilterNumericColumnFilter, ColumnFilterStringColumnFilter
+]