feat(api): update via SDK Studio (#272)

stainless-app[bot] · stainless-app[bot] · commit 6d2708a1f2cf · 2024-07-23T00:41:39.000Z
diff --git a/.stats.yml b/.stats.yml
@@ -1 +1 @@
-configured_endpoints: 10
+configured_endpoints: 12
diff --git a/api.md b/api.md
@@ -52,6 +52,17 @@ Methods:
 
 # InferencePipelines
 
+Types:
+
+```python
+from openlayer.types import InferencePipelineRetrieveResponse
+```
+
+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_response.py">InferencePipelineRetrieveResponse</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>
+
 ## Data
 
 Types:
diff --git a/src/openlayer/resources/inference_pipelines/inference_pipelines.py b/src/openlayer/resources/inference_pipelines/inference_pipelines.py
@@ -2,6 +2,8 @@
 
 from __future__ import annotations
 
+import httpx
+
 from .data import (
     DataResource,
     AsyncDataResource,
@@ -18,8 +20,15 @@
     RowsResourceWithStreamingResponse,
     AsyncRowsResourceWithStreamingResponse,
 )
+from ..._types import NOT_GIVEN, Body, Query, Headers, NoneType, NotGiven
 from ..._compat import cached_property
 from ..._resource import SyncAPIResource, AsyncAPIResource
+from ..._response import (
+    to_raw_response_wrapper,
+    to_streamed_response_wrapper,
+    async_to_raw_response_wrapper,
+    async_to_streamed_response_wrapper,
+)
 from .test_results import (
     TestResultsResource,
     AsyncTestResultsResource,
@@ -28,6 +37,8 @@
     TestResultsResourceWithStreamingResponse,
     AsyncTestResultsResourceWithStreamingResponse,
 )
+from ..._base_client import make_request_options
+from ...types.inference_pipeline_retrieve_response import InferencePipelineRetrieveResponse
 
 __all__ = ["InferencePipelinesResource", "AsyncInferencePipelinesResource"]
 
@@ -53,6 +64,77 @@ def with_raw_response(self) -> InferencePipelinesResourceWithRawResponse:
     def with_streaming_response(self) -> InferencePipelinesResourceWithStreamingResponse:
         return InferencePipelinesResourceWithStreamingResponse(self)
 
+    def retrieve(
+        self,
+        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,
+    ) -> InferencePipelineRetrieveResponse:
+        """
+        Retrieve inference pipeline.
+
+        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}"
+            )
+        return self._get(
+            f"/inference-pipelines/{inference_pipeline_id}",
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=InferencePipelineRetrieveResponse,
+        )
+
+    def delete(
+        self,
+        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 inference pipeline.
+
+        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}"
+            )
+        extra_headers = {"Accept": "*/*", **(extra_headers or {})}
+        return self._delete(
+            f"/inference-pipelines/{inference_pipeline_id}",
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=NoneType,
+        )
+
 
 class AsyncInferencePipelinesResource(AsyncAPIResource):
     @cached_property
@@ -75,11 +157,89 @@ def with_raw_response(self) -> AsyncInferencePipelinesResourceWithRawResponse:
     def with_streaming_response(self) -> AsyncInferencePipelinesResourceWithStreamingResponse:
         return AsyncInferencePipelinesResourceWithStreamingResponse(self)
 
+    async def retrieve(
+        self,
+        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,
+    ) -> InferencePipelineRetrieveResponse:
+        """
+        Retrieve inference pipeline.
+
+        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}"
+            )
+        return await self._get(
+            f"/inference-pipelines/{inference_pipeline_id}",
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=InferencePipelineRetrieveResponse,
+        )
+
+    async def delete(
+        self,
+        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 inference pipeline.
+
+        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}"
+            )
+        extra_headers = {"Accept": "*/*", **(extra_headers or {})}
+        return await self._delete(
+            f"/inference-pipelines/{inference_pipeline_id}",
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=NoneType,
+        )
+
 
 class InferencePipelinesResourceWithRawResponse:
     def __init__(self, inference_pipelines: InferencePipelinesResource) -> None:
         self._inference_pipelines = inference_pipelines
 
+        self.retrieve = to_raw_response_wrapper(
+            inference_pipelines.retrieve,
+        )
+        self.delete = to_raw_response_wrapper(
+            inference_pipelines.delete,
+        )
+
     @cached_property
     def data(self) -> DataResourceWithRawResponse:
         return DataResourceWithRawResponse(self._inference_pipelines.data)
@@ -97,6 +257,13 @@ class AsyncInferencePipelinesResourceWithRawResponse:
     def __init__(self, inference_pipelines: AsyncInferencePipelinesResource) -> None:
         self._inference_pipelines = inference_pipelines
 
+        self.retrieve = async_to_raw_response_wrapper(
+            inference_pipelines.retrieve,
+        )
+        self.delete = async_to_raw_response_wrapper(
+            inference_pipelines.delete,
+        )
+
     @cached_property
     def data(self) -> AsyncDataResourceWithRawResponse:
         return AsyncDataResourceWithRawResponse(self._inference_pipelines.data)
@@ -114,6 +281,13 @@ class InferencePipelinesResourceWithStreamingResponse:
     def __init__(self, inference_pipelines: InferencePipelinesResource) -> None:
         self._inference_pipelines = inference_pipelines
 
+        self.retrieve = to_streamed_response_wrapper(
+            inference_pipelines.retrieve,
+        )
+        self.delete = to_streamed_response_wrapper(
+            inference_pipelines.delete,
+        )
+
     @cached_property
     def data(self) -> DataResourceWithStreamingResponse:
         return DataResourceWithStreamingResponse(self._inference_pipelines.data)
@@ -131,6 +305,13 @@ class AsyncInferencePipelinesResourceWithStreamingResponse:
     def __init__(self, inference_pipelines: AsyncInferencePipelinesResource) -> None:
         self._inference_pipelines = inference_pipelines
 
+        self.retrieve = async_to_streamed_response_wrapper(
+            inference_pipelines.retrieve,
+        )
+        self.delete = async_to_streamed_response_wrapper(
+            inference_pipelines.delete,
+        )
+
     @cached_property
     def data(self) -> AsyncDataResourceWithStreamingResponse:
         return AsyncDataResourceWithStreamingResponse(self._inference_pipelines.data)
diff --git a/src/openlayer/types/__init__.py b/src/openlayer/types/__init__.py
@@ -6,3 +6,4 @@
 from .project_create_params import ProjectCreateParams as ProjectCreateParams
 from .project_list_response import ProjectListResponse as ProjectListResponse
 from .project_create_response import ProjectCreateResponse as ProjectCreateResponse
+from .inference_pipeline_retrieve_response import InferencePipelineRetrieveResponse as InferencePipelineRetrieveResponse
diff --git a/src/openlayer/types/inference_pipeline_retrieve_response.py b/src/openlayer/types/inference_pipeline_retrieve_response.py
@@ -0,0 +1,61 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from typing import Optional
+from datetime import datetime
+from typing_extensions import Literal
+
+from pydantic import Field as FieldInfo
+
+from .._models import BaseModel
+
+__all__ = ["InferencePipelineRetrieveResponse", "Links"]
+
+
+class Links(BaseModel):
+    app: str
+
+
+class InferencePipelineRetrieveResponse(BaseModel):
+    id: str
+    """The inference pipeline id."""
+
+    date_created: datetime = FieldInfo(alias="dateCreated")
+    """The creation date."""
+
+    date_last_evaluated: Optional[datetime] = FieldInfo(alias="dateLastEvaluated", default=None)
+    """The last test evaluation date."""
+
+    date_last_sample_received: Optional[datetime] = FieldInfo(alias="dateLastSampleReceived", default=None)
+    """The last data sample received date."""
+
+    date_of_next_evaluation: Optional[datetime] = FieldInfo(alias="dateOfNextEvaluation", default=None)
+    """The next test evaluation date."""
+
+    date_updated: datetime = FieldInfo(alias="dateUpdated")
+    """The last updated date."""
+
+    description: Optional[str] = None
+    """The inference pipeline description."""
+
+    failing_goal_count: int = FieldInfo(alias="failingGoalCount")
+    """The number of tests failing."""
+
+    links: Links
+
+    name: str
+    """The inference pipeline name."""
+
+    passing_goal_count: int = FieldInfo(alias="passingGoalCount")
+    """The number of tests passing."""
+
+    project_id: str = FieldInfo(alias="projectId")
+    """The project id."""
+
+    status: Literal["queued", "running", "paused", "failed", "completed", "unknown"]
+    """The status of test evaluation for the inference pipeline."""
+
+    status_message: Optional[str] = FieldInfo(alias="statusMessage", default=None)
+    """The status message of test evaluation for the inference pipeline."""
+
+    total_goal_count: int = FieldInfo(alias="totalGoalCount")
+    """The total number of tests."""
diff --git a/tests/api_resources/test_inference_pipelines.py b/tests/api_resources/test_inference_pipelines.py

Original file line number	Diff line number	Diff line change
`@@ -1 +1 @@`
`1`		`-configured_endpoints: 10`
	`1`	`+configured_endpoints: 12`