docs(closes OPEN-9953): expose endpoints to get and delete a row

Author: stainless-app[bot]

.stats.yml

@@ -1,3 +1,3 @@
-configured_endpoints: 29
-openapi_spec_hash: 20caa671b1b1a87c0a5cb6ebd7e4b064
-config_hash: aaf12ae1da71c62ca5195fc2b66f657c
+configured_endpoints: 31
+openapi_spec_hash: a574ef9082e992c25120554886a9ab7a
+config_hash: f8fb410519268f9f228074c9344acc1f

api.md

@@ -152,13 +152,19 @@ Methods:
 Types:
 
 ```python
-from openlayer.types.inference_pipelines import RowUpdateResponse, RowListResponse
+from openlayer.types.inference_pipelines import (
+    RowRetrieveResponse,
+    RowUpdateResponse,
+    RowListResponse,
+)
 ```
 
 Methods:
 
+- <code title="get /inference-pipelines/{inferencePipelineId}/rows/{inferenceId}">client.inference_pipelines.rows.<a href="./src/openlayer/resources/inference_pipelines/rows.py">retrieve</a>(inference_id, \*, inference_pipeline_id) -> <a href="./src/openlayer/types/inference_pipelines/row_retrieve_response.py">RowRetrieveResponse</a></code>
 - <code title="put /inference-pipelines/{inferencePipelineId}/rows">client.inference_pipelines.rows.<a href="./src/openlayer/resources/inference_pipelines/rows.py">update</a>(inference_pipeline_id, \*\*<a href="src/openlayer/types/inference_pipelines/row_update_params.py">params</a>) -> <a href="./src/openlayer/types/inference_pipelines/row_update_response.py">RowUpdateResponse</a></code>
 - <code title="post /inference-pipelines/{inferencePipelineId}/rows">client.inference_pipelines.rows.<a href="./src/openlayer/resources/inference_pipelines/rows.py">list</a>(inference_pipeline_id, \*\*<a href="src/openlayer/types/inference_pipelines/row_list_params.py">params</a>) -> <a href="./src/openlayer/types/inference_pipelines/row_list_response.py">RowListResponse</a></code>
+- <code title="delete /inference-pipelines/{inferencePipelineId}/rows/{inferenceId}">client.inference_pipelines.rows.<a href="./src/openlayer/resources/inference_pipelines/rows.py">delete</a>(inference_id, \*, inference_pipeline_id) -> None</code>
 
 ## TestResults
 

src/openlayer/resources/inference_pipelines/rows.py

@@ -6,7 +6,7 @@
 
 import httpx
 
-from ..._types import Body, Omit, Query, Headers, NotGiven, SequenceNotStr, omit, not_given
+from ..._types import Body, Omit, Query, Headers, NoneType, NotGiven, SequenceNotStr, omit, not_given
 from ..._utils import path_template, maybe_transform, async_maybe_transform
 from ..._compat import cached_property
 from ..._resource import SyncAPIResource, AsyncAPIResource
@@ -20,6 +20,7 @@
 from ...types.inference_pipelines import row_list_params, row_update_params
 from ...types.inference_pipelines.row_list_response import RowListResponse
 from ...types.inference_pipelines.row_update_response import RowUpdateResponse
+from ...types.inference_pipelines.row_retrieve_response import RowRetrieveResponse
 
 __all__ = ["RowsResource", "AsyncRowsResource"]
 
@@ -44,6 +45,48 @@ def with_streaming_response(self) -> RowsResourceWithStreamingResponse:
         """
         return RowsResourceWithStreamingResponse(self)
 
+    def retrieve(
+        self,
+        inference_id: str,
+        *,
+        inference_pipeline_id: str,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = not_given,
+    ) -> RowRetrieveResponse:
+        """
+        Fetch a single inference pipeline row by inference ID, including OTel steps.
+
+        Args:
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not inference_pipeline_id:
+            raise ValueError(
+                f"Expected a non-empty value for `inference_pipeline_id` but received {inference_pipeline_id!r}"
+            )
+        if not inference_id:
+            raise ValueError(f"Expected a non-empty value for `inference_id` but received {inference_id!r}")
+        return self._get(
+            path_template(
+                "/inference-pipelines/{inference_pipeline_id}/rows/{inference_id}",
+                inference_pipeline_id=inference_pipeline_id,
+                inference_id=inference_id,
+            ),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=RowRetrieveResponse,
+        )
+
     def update(
         self,
         inference_pipeline_id: str,
@@ -177,6 +220,51 @@ def list(
             cast_to=RowListResponse,
         )
 
+    def delete(
+        self,
+        inference_id: str,
+        *,
+        inference_pipeline_id: str,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = not_given,
+    ) -> None:
+        """Delete a single inference pipeline row by inference ID.
+
+        Only project admins can
+        perform this action.
+
+        Args:
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not inference_pipeline_id:
+            raise ValueError(
+                f"Expected a non-empty value for `inference_pipeline_id` but received {inference_pipeline_id!r}"
+            )
+        if not inference_id:
+            raise ValueError(f"Expected a non-empty value for `inference_id` but received {inference_id!r}")
+        extra_headers = {"Accept": "*/*", **(extra_headers or {})}
+        return self._delete(
+            path_template(
+                "/inference-pipelines/{inference_pipeline_id}/rows/{inference_id}",
+                inference_pipeline_id=inference_pipeline_id,
+                inference_id=inference_id,
+            ),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=NoneType,
+        )
+
 
 class AsyncRowsResource(AsyncAPIResource):
     @cached_property
@@ -198,6 +286,48 @@ def with_streaming_response(self) -> AsyncRowsResourceWithStreamingResponse:
         """
         return AsyncRowsResourceWithStreamingResponse(self)
 
+    async def retrieve(
+        self,
+        inference_id: str,
+        *,
+        inference_pipeline_id: str,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = not_given,
+    ) -> RowRetrieveResponse:
+        """
+        Fetch a single inference pipeline row by inference ID, including OTel steps.
+
+        Args:
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not inference_pipeline_id:
+            raise ValueError(
+                f"Expected a non-empty value for `inference_pipeline_id` but received {inference_pipeline_id!r}"
+            )
+        if not inference_id:
+            raise ValueError(f"Expected a non-empty value for `inference_id` but received {inference_id!r}")
+        return await self._get(
+            path_template(
+                "/inference-pipelines/{inference_pipeline_id}/rows/{inference_id}",
+                inference_pipeline_id=inference_pipeline_id,
+                inference_id=inference_id,
+            ),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=RowRetrieveResponse,
+        )
+
     async def update(
         self,
         inference_pipeline_id: str,
@@ -331,50 +461,119 @@ async def list(
             cast_to=RowListResponse,
         )
 
+    async def delete(
+        self,
+        inference_id: str,
+        *,
+        inference_pipeline_id: str,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = not_given,
+    ) -> None:
+        """Delete a single inference pipeline row by inference ID.
+
+        Only project admins can
+        perform this action.
+
+        Args:
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not inference_pipeline_id:
+            raise ValueError(
+                f"Expected a non-empty value for `inference_pipeline_id` but received {inference_pipeline_id!r}"
+            )
+        if not inference_id:
+            raise ValueError(f"Expected a non-empty value for `inference_id` but received {inference_id!r}")
+        extra_headers = {"Accept": "*/*", **(extra_headers or {})}
+        return await self._delete(
+            path_template(
+                "/inference-pipelines/{inference_pipeline_id}/rows/{inference_id}",
+                inference_pipeline_id=inference_pipeline_id,
+                inference_id=inference_id,
+            ),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=NoneType,
+        )
+
 
 class RowsResourceWithRawResponse:
     def __init__(self, rows: RowsResource) -> None:
         self._rows = rows
 
+        self.retrieve = to_raw_response_wrapper(
+            rows.retrieve,
+        )
         self.update = to_raw_response_wrapper(
             rows.update,
         )
         self.list = to_raw_response_wrapper(
             rows.list,
         )
+        self.delete = to_raw_response_wrapper(
+            rows.delete,
+        )
 
 
 class AsyncRowsResourceWithRawResponse:
     def __init__(self, rows: AsyncRowsResource) -> None:
         self._rows = rows
 
+        self.retrieve = async_to_raw_response_wrapper(
+            rows.retrieve,
+        )
         self.update = async_to_raw_response_wrapper(
             rows.update,
         )
         self.list = async_to_raw_response_wrapper(
             rows.list,
         )
+        self.delete = async_to_raw_response_wrapper(
+            rows.delete,
+        )
 
 
 class RowsResourceWithStreamingResponse:
     def __init__(self, rows: RowsResource) -> None:
         self._rows = rows
 
+        self.retrieve = to_streamed_response_wrapper(
+            rows.retrieve,
+        )
         self.update = to_streamed_response_wrapper(
             rows.update,
         )
         self.list = to_streamed_response_wrapper(
             rows.list,
         )
+        self.delete = to_streamed_response_wrapper(
+            rows.delete,
+        )
 
 
 class AsyncRowsResourceWithStreamingResponse:
     def __init__(self, rows: AsyncRowsResource) -> None:
         self._rows = rows
 
+        self.retrieve = async_to_streamed_response_wrapper(
+            rows.retrieve,
+        )
         self.update = async_to_streamed_response_wrapper(
             rows.update,
         )
         self.list = async_to_streamed_response_wrapper(
             rows.list,
         )
+        self.delete = async_to_streamed_response_wrapper(
+            rows.delete,
+        )

src/openlayer/types/inference_pipelines/__init__.py

@@ -8,5 +8,6 @@
 from .data_stream_params import DataStreamParams as DataStreamParams
 from .row_update_response import RowUpdateResponse as RowUpdateResponse
 from .data_stream_response import DataStreamResponse as DataStreamResponse
+from .row_retrieve_response import RowRetrieveResponse as RowRetrieveResponse
 from .test_result_list_params import TestResultListParams as TestResultListParams
 from .test_result_list_response import TestResultListResponse as TestResultListResponse

src/openlayer/types/inference_pipelines/row_retrieve_response.py

@@ -0,0 +1,13 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from typing import Optional
+
+from ..._models import BaseModel
+
+__all__ = ["RowRetrieveResponse"]
+
+
+class RowRetrieveResponse(BaseModel):
+    row: Optional[object] = None
+
+    success: Optional[bool] = None