o {$f/@sddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z ddl mZddlmZdd lmZmZdd lmZmZdd lmZmZdd lmZmZdd lmZddlm Z ddgZ!GdddeZ"GdddeZ#GdddZ$GdddZ%GdddZ&GdddZ'dS)) annotations)LiteralN)_legacy_response) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)step_list_params)RunStepSteps AsyncStepsc @\eZdZed$ddZed%ddZddded d&ddZeeeedddedd'd"d#ZdS)(rreturnStepsWithRawResponsecCt|SN)rselfr ^/var/www/html/dev/env/lib/python3.10/site-packages/openai/resources/beta/threads/runs/steps.pywith_raw_responsezSteps.with_raw_responseStepsWithStreamingResponsecCrr)r$rr r r!with_streaming_responser#zSteps.with_streaming_responseN extra_headers extra_query extra_bodytimeoutstep_idstr thread_idrun_idr'Headers | Noner( Query | Noner) Body | Noner*'float | httpx.Timeout | None | NotGivenrcCst|s td||std||std|ddi|p!i}|jd|d|d|t||||d td S) I Retrieves a run step. 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 8Expected a non-empty value for `thread_id` but received 5Expected a non-empty value for `run_id` but received 6Expected a non-empty value for `step_id` but received OpenAI-Beta assistants=v2 /threads//runs//steps/r&optionscast_to ValueError_getrrrr+r-r.r'r(r)r*r r r!retrieve#szSteps.retrieveafterbeforelimitorderr'r(r)r*rEstr | NotGivenrFrGint | NotGivenrH!Literal['asc', 'desc'] | NotGivenSyncCursorPage[RunStep]c Cx|s td||std|ddi|pi}|jd|d|dttt||| | t||||dtjd td S a! Returns a list of run steps belonging to a run. Args: after: A cursor for use in pagination. `after` is an object ID that defines your place in the list. For instance, if you make a list request and receive 100 objects, ending with obj_foo, your subsequent call can include after=obj_foo in order to fetch the next page of the list. before: A cursor for use in pagination. `before` is an object ID that defines your place in the list. For instance, if you make a list request and receive 100 objects, ending with obj_foo, your subsequent call can include before=obj_foo in order to fetch the previous page of the list. limit: A limit on the number of objects to be returned. Limit can range between 1 and 100, and the default is 20. order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending order and `desc` for descending order. 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 r4r5r7r8r9r:z/steps)rErFrGrH)r'r(r)r*query)pager=model)r@ _get_api_listrrrr rStepListParams rr.r-rErFrGrHr'r(r)r*r r r!listK0,z Steps.list)rr)rr$r+r,r-r,r.r,r'r/r(r0r)r1r*r2rr)r.r,r-r,rErIrFrIrGrJrHrKr'r/r(r0r)r1r*r2rrL __name__ __module__ __qualname__r r"r%rrCrUr r r r!r&   -c @r)(rrAsyncStepsWithRawResponsecCrr)r]rr r r!r"r#zAsyncSteps.with_raw_responseAsyncStepsWithStreamingResponsecCrr)r^rr r r!r%r#z"AsyncSteps.with_streaming_responseNr&r+r,r-r.r'r/r(r0r)r1r*r2rcs||s td||std||std|ddi|p"i}|jd|d|d|t||||d td Id HS) r3r4r5r6r7r8r9r:r;r&r<Nr?rBr r r!rCs zAsyncSteps.retrieverDrErIrFrGrJrHrK1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]c CrMrN)r@rRrrrr rrSrTr r r!rUrVzAsyncSteps.list)rr])rr^rW)r.r,r-r,rErIrFrIrGrJrHrKr'r/r(r0r)r1r*r2rr_rXr r r r!rr\c@eZdZdddZdS) rstepsrrNonecC&||_t|j|_t|j|_dSr)_stepsrto_raw_response_wrapperrCrUrrar r r!__init__  zStepsWithRawResponse.__init__NrarrrbrYrZr[rgr r r r!r rc@r`) r]rarrrbcCrcr)rdrasync_to_raw_response_wrapperrCrUrfr r r!rgrhz"AsyncStepsWithRawResponse.__init__Nrarrrbrjr r r r!r]rkr]c@r`) r$rarrrbcC"||_t|j|_t|j|_dSr)rdrrCrUrfr r r!rg# z#StepsWithStreamingResponse.__init__Nrirjr r r r!r$"rkr$c@r`) r^rarrrbcCrnr)rdrrCrUrfr r r!rg/roz(AsyncStepsWithStreamingResponse.__init__Nrmrjr r r r!r^.rkr^)( __future__rtyping_extensionsrhttpxr_typesrrrr r _utilsr _compatr _resourcer r _responserr paginationrr _base_clientrrtypes.beta.threads.runsr types.beta.threads.runs.run_stepr__all__rrrr]r$r^r r r r!s(       xx