o ilD@sPddlmZddlZddlmZddlmZddlZddlmZddl m Z m Z m Z m Z mZmZmZddlmZmZmZdd lmZdd lmZmZdd lmZmZdd lmZmZdd l m!Z!m"Z"ddl#m$Z$m%Z%ddl&m'Z'ddl(m)Z)ddgZ*GdddeZ+GdddeZ,GdddZ-GdddZ.GdddZ/GdddZ0dS)) annotationsN)List)Literal)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_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(b/home/kim/smarthome/.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_idr2List[RunStepInclude] | Omitr3Headers | Noner4 Query | Noner5 Body | Noner6'float | httpx.Timeout | None | NotGivenrc Cs||s td||std||std|ddi|p!i}|jtd|||dt||||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=v22/threads/{thread_id}/runs/{run_id}/steps/{step_id}r9r:r7r2r3r4r5r6queryoptionsZcast_to) ValueError_getrrrrStepRetrieveParamsr r'r7r9r:r2r3r4r5r6r(r(r)retrieve0s.#zSteps.retrieve afterbeforer2limitorderr3r4r5r6rR str | OmitrSrT int | OmitrULiteral['asc', 'desc'] | OmitSyncCursorPage[RunStep]c Cv|s td||std|ddi|pi}|jtd||dttt|| | | t|||||dtjdtd 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 rArBrDrEz(/threads/{thread_id}/runs/{run_id}/steps)r9r:)rRrSr2rTrUrH)pagerKmodel) rL _get_api_listrrrrrrStepListParams r'r:r9rRrSr2rTrUr3r4r5r6r(r(r)listk26 z Steps.list)r"r#)r"r,r7r8r9r8r:r8r2r;r3r<r4r=r5r>r6r?r"r)r:r8r9r8rRrVrSrVr2r;rTrWrUrXr3r<r4r=r5r>r6r?r"rY __name__ __module__ __qualname____doc__rr*r.typing_extensions deprecatedr r rPrar(r(r(r)r0  :c @r ),rr!r"AsyncStepsWithRawResponsecCr$r%)rlr&r(r(r)r*r+zAsyncSteps.with_raw_responseAsyncStepsWithStreamingResponsecCr$r-)rmr&r(r(r)r.r/z"AsyncSteps.with_streaming_responser0Nr1r7r8r9r:r2r;r3r<r4r=r5r>r6r?rc s|s td||std||std|ddi|p"i}|jtd|||dt||||td|itjId Hd td Id HS) r@rArBrCrDrErFrGr2NrHrJ)rLrMrrrrrNrrOr(r(r)rPs0# zAsyncSteps.retrieverQrRrVrSrTrWrUrX1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]c CrZr[) rLr^rrrrrrr_r`r(r(r)rarbzAsyncSteps.list)r"rl)r"rmrc)r:r8r9r8rRrVrSrVr2r;rTrWrUrXr3r<r4r=r5r>r6r?r"rnrdr(r(r(r)rrkc@eZdZdddZdS) r#stepsrr"NonecC&||_t|j|_t|j|_dSN)_stepsrZto_raw_response_wrapperrPrar'rpr(r(r)__init__azStepsWithRawResponse.__init__Nrprr"rqrerfrgrvr(r(r(r)r#`r#c@ro) rlrprr"rqcCrrrs)rtrZasync_to_raw_response_wrapperrPrarur(r(r)rvqrwz"AsyncStepsWithRawResponse.__init__Nrprr"rqryr(r(r(r)rlprzrlc@ro) r,rprr"rqcC"||_t|j|_t|j|_dSrs)rtrrPrarur(r(r)rvz#StepsWithStreamingResponse.__init__Nrxryr(r(r(r)r,rzr,c@ro) rmrprr"rqcCr|rs)rtrrPrarur(r(r)rvr}z(AsyncStepsWithStreamingResponse.__init__Nr{ryr(r(r(r)rmrzrm)1 __future__rritypingrrZhttpxr_typesrrr r r r r Z_utilsrrrZ_compatrZ _resourcerr _responserrZ paginationrrZ _base_clientrrZtypes.beta.threads.runsrrZ types.beta.threads.runs.run_steprZ(types.beta.threads.runs.run_step_includer__all__rrr#rlr,rmr(r(r(r)s2    $   $$