o r)iB@sLddlmZddlZddlmZddlmZddlZddlmZddl m Z m Z m Z m Z mZmZmZddlmZmZdd lmZdd lmZmZdd lmZmZdd lmZmZdd lm Z m!Z!ddl"m#Z#m$Z$ddl%m&Z&ddl'm(Z(ddgZ)GdddeZ*GdddeZ+GdddZ,GdddZ-GdddZ.GdddZ/dS)) annotationsN)List)Literal)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given)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 @xeZdZdZed(ddZed)ddZed e d d d e d d*ddZ ed e e e e e d d d e d d+d&d'Z d S),r4Build Assistants that can call models and use tools.returnStepsWithRawResponsecCt|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 )r"selfr'l/var/www/html/voicebot/backend/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_idr1List[RunStepInclude] | Omitr2Headers | Noner3 Query | Noner4 Body | Noner5'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/r1r2r3r4r5queryoptionscast_to) ValueError_getrrrStepRetrieveParamsr r&r6r8r9r1r2r3r4r5r'r'r(retrieve0s$#zSteps.retrieve afterbeforer1limitorderr2r3r4r5rS str | OmitrTrU int | OmitrVLiteral['asc', 'desc'] | OmitSyncCursorPage[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@rArCrDrErFz/steps)rSrTr1rUrVrH)pagerKmodel)rM _get_api_listrrrrrStepListParams r&r9r8rSrTr1rUrVr2r3r4r5r'r'r(listf26z Steps.list)r!r")r!r+r6r7r8r7r9r7r1r:r2r;r3r<r4r=r5r>r!r)r9r7r8r7rSrWrTrWr1r:rUrXrVrYr2r;r3r<r4r=r5r>r!rZ __name__ __module__ __qualname____doc__rr)r-typing_extensions deprecatedr r rQrbr'r'r'r(r0  5c @r),rr r!AsyncStepsWithRawResponsecCr#r$)rmr%r'r'r(r)r*zAsyncSteps.with_raw_responseAsyncStepsWithStreamingResponsecCr#r,)rnr%r'r'r(r-r.z"AsyncSteps.with_streaming_responser/Nr0r6r7r8r9r1r:r2r;r3r<r4r=r5r>rc s|s td||std||std|ddi|p"i}|jd|d|d|t||||td |itjId Hd td Id HS) r?r@rArBrCrDrErFrGr1NrHrJ)rMrNrrrrOrrPr'r'r(rQs&# zAsyncSteps.retrieverRrSrWrTrUrXrVrY1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]c Cr[r\)rMr_rrrrrr`rar'r'r(rbrczAsyncSteps.list)r!rm)r!rnrd)r9r7r8r7rSrWrTrWr1r:rUrXrVrYr2r;r3r<r4r=r5r>r!rorer'r'r'r(rrlc@eZdZdddZdS) r"stepsrr!NonecC&||_t|j|_t|j|_dSN)_stepsrto_raw_response_wrapperrQrbr&rqr'r'r(__init__WzStepsWithRawResponse.__init__Nrqrr!rrrfrgrhrxr'r'r'r(r"Vr"c@rp) rmrqrr!rrcCrsrt)rurasync_to_raw_response_wrapperrQrbrwr'r'r(rxgryz"AsyncStepsWithRawResponse.__init__Nrqrr!rrr{r'r'r'r(rmfr|rmc@rp) r+rqrr!rrcC"||_t|j|_t|j|_dSrt)rurrQrbrwr'r'r(rxwz#StepsWithStreamingResponse.__init__Nrzr{r'r'r'r(r+vr|r+c@rp) rnrqrr!rrcCrrt)rurrQrbrwr'r'r(rxrz(AsyncStepsWithStreamingResponse.__init__Nr~r{r'r'r'r(rnr|rn)0 __future__rrjtypingrrhttpxr_typesrrr r r r r _utilsrr_compatr _resourcerr _responserr paginationrr _base_clientrrtypes.beta.threads.runsrr types.beta.threads.runs.run_stepr(types.beta.threads.runs.run_step_includer__all__rrr"rmr+rnr'r'r'r(s2    $