o /wiB@sDddlmZddlZddlmZddlmZddlZddlmZddl m Z m Z m Z m Z mZddlmZmZdd lmZdd lmZmZdd lmZmZdd lmZmZdd lmZmZddl m!Z!m"Z"ddl#m$Z$ddl%m&Z&ddgZ'GdddeZ(GdddeZ)GdddZ*GdddZ+GdddZ,GdddZ-dS)) annotationsN)List)Literal)_legacy_response) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)step_list_paramsstep_retrieve_params)RunStep)RunStepIncludeSteps AsyncStepsc @teZdZed'ddZed(ddZeded d d ed d)ddZ edeeeeed d d ed d*d%d&Z d S)+rreturnStepsWithRawResponsecCt|Sa This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. For more information, see https://www.github.com/openai/openai-python#accessing-raw-response-data-eg-headers )rselfr$e/home/ubuntu/sommelier/.venv/lib/python3.10/site-packages/openai/resources/beta/threads/runs/steps.pywith_raw_responsezSteps.with_raw_responseStepsWithStreamingResponsecCr z An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/openai/openai-python#with_streaming_response )r(r"r$r$r%with_streaming_response%zSteps.with_streaming_response>The Assistants API is deprecated in favor of the Responses APINinclude extra_headers extra_query extra_bodytimeoutstep_idstr thread_idrun_idr.List[RunStepInclude] | NotGivenr/Headers | Noner0 Query | Noner1 Body | Noner2'float | httpx.Timeout | None | NotGivenrc Cs|s td||std||std|ddi|p!i}|jd|d|d|t||||td |itjd td S)  Retrieves a run step. Args: include: A list of additional fields to include in the response. Currently the only supported value is `step_details.tool_calls[*].file_search.results[*].content` to fetch the file search result content. See the [file search tool documentation](https://platform.openai.com/docs/assistants/tools/file-search#customizing-file-search-settings) for more information. 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.r/r0r1r2queryoptionscast_to) ValueError_getrr rStepRetrieveParamsr r#r3r5r6r.r/r0r1r2r$r$r%retrieve.s$#zSteps.retrieve afterbeforer.limitorderr/r0r1r2rPstr | NotGivenrQrRint | NotGivenrS!Literal['asc', 'desc'] | NotGivenSyncCursorPage[RunStep]c Cz|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, starting with obj_foo, your subsequent call can include before=obj_foo in order to fetch the previous page of the list. include: A list of additional fields to include in the response. Currently the only supported value is `step_details.tool_calls[*].file_search.results[*].content` to fetch the file search result content. See the [file search tool documentation](https://platform.openai.com/docs/assistants/tools/file-search#customizing-file-search-settings) for more information. 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 r=r>r@rArBrCz/steps)rPrQr.rRrSrE)pagerHmodel)rJ _get_api_listrrrr rStepListParams r#r6r5rPrQr.rRrSr/r0r1r2r$r$r%listd26z Steps.list)rr)rr(r3r4r5r4r6r4r.r7r/r8r0r9r1r:r2r;rr)r6r4r5r4rPrTrQrTr.r7rRrUrSrVr/r8r0r9r1r:r2r;rrW __name__ __module__ __qualname__rr&r*typing_extensions deprecatedrrNr_r$r$r$r%r.  5c @r)+rrAsyncStepsWithRawResponsecCr r!)rir"r$r$r%r&r'zAsyncSteps.with_raw_responseAsyncStepsWithStreamingResponsecCr r))rjr"r$r$r%r*r+z"AsyncSteps.with_streaming_responser,Nr-r3r4r5r6r.r7r/r8r0r9r1r:r2r;rc s|s td||std||std|ddi|p"i}|jd|d|d|t||||td |itjId Hd td Id HS) r<r=r>r?r@rArBrCrDr.NrErG)rJrKrr rrLrrMr$r$r%rNs&# zAsyncSteps.retrieverOrPrTrQrRrUrSrV1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]c CrXrY)rJr\rrrr rr]r^r$r$r%r_r`zAsyncSteps.list)rri)rrjra)r6r4r5r4rPrTrQrTr.r7rRrUrSrVr/r8r0r9r1r:r2r;rrkrbr$r$r$r%rrhc@eZdZdddZdS) rstepsrrNonecC&||_t|j|_t|j|_dSN)_stepsrto_raw_response_wrapperrNr_r#rmr$r$r%__init__SzStepsWithRawResponse.__init__Nrmrrrnrcrdrertr$r$r$r%rRrc@rl) rirmrrrncCrorp)rqrasync_to_raw_response_wrapperrNr_rsr$r$r%rtcruz"AsyncStepsWithRawResponse.__init__Nrmrrrnrwr$r$r$r%ribrxric@rl) r(rmrrrncC"||_t|j|_t|j|_dSrp)rqrrNr_rsr$r$r%rtsz#StepsWithStreamingResponse.__init__Nrvrwr$r$r$r%r(rrxr(c@rl) rjrmrrrncCr{rp)rqrrNr_rsr$r$r%rtr|z(AsyncStepsWithStreamingResponse.__init__Nrzrwr$r$r$r%rjrxrj). __future__rrftypingrrhttpxr_typesrrr r r _utilsr r _compatr _resourcerr _responserr paginationrr _base_clientrrtypes.beta.threads.runsrr types.beta.threads.runs.run_stepr(types.beta.threads.runs.run_step_includer__all__rrrrir(rjr$r$r$r%s2