a _g=@s<ddlmZddlmZddlmZddlZddlmZddl 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)) annotations)List)LiteralN)_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@seZdZeddddZeddddZeddded d d d d d d dddd ddZeeeeeddded d d ddd ddd d dddd ddZdS)rStepsWithRawResponsereturncCst|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#v/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/openai/resources/beta/threads/runs/steps.pywith_raw_responseszSteps.with_raw_responseStepsWithStreamingResponsecCst|Sz 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'szSteps.with_streaming_responseNinclude extra_headers extra_query extra_bodytimeoutstrList[RunStepInclude] | NotGivenHeaders | None Query | None Body | None'float | httpx.Timeout | None | NotGivenr step_id thread_idrun_idr*r+r,r-r.rc Cs|std||s$td||s6td|ddi|pBi}|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+r,r-r.queryoptionsZcast_to) ValueError_getrr rStepRetrieveParamsr r"r6r7r8r*r+r,r-r.r#r#r$retrieve0s$"zSteps.retrieve afterbeforer*limitorderr+r,r-r.str | NotGivenint | NotGiven!Literal['asc', 'desc'] | NotGivenzSyncCursorPage[RunStep] r8r7rLrMr*rNrOr+r,r-r.rc Csz|std||s$td|ddi|p0i}|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=r>r?r@z/steps)rLrMr*rNrOrB)pagerEmodel)rF _get_api_listrrrr rStepListParams r"r8r7rLrMr*rNrOr+r,r-r.r#r#r$listes25z Steps.list __name__ __module__ __qualname__rr%r(rrJrZr#r#r#r$rs( ":c@seZdZeddddZeddddZeddded d d d d d d dddd ddZeeeeeddded d d ddd ddd d dddd ddZdS)rAsyncStepsWithRawResponsercCst|Sr )r_r!r#r#r$r%szAsyncSteps.with_raw_responseAsyncStepsWithStreamingResponsecCst|Sr')r`r!r#r#r$r(sz"AsyncSteps.with_streaming_responseNr)r/r0r1r2r3r4rr5c s|std||s$td||s6td|ddi|pBi}|jd|d|d|t||||td |itjId Hd td Id HS) r9r:r;r<r=r>r?r@rAr*NrBrD)rFrGrr rrHrrIr#r#r$rJs$"zAsyncSteps.retrieverKrPrQrRz1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]rSc Csz|std||s$td|ddi|p0i}|jd|d|dttt|| | | t|||||dtjd td SrT)rFrWrrrr rrXrYr#r#r$rZs25zAsyncSteps.listr[r#r#r#r$rs( ":c@seZdZdddddZdS)rrNonestepsrcCs&||_t|j|_t|j|_dSN)_stepsrZto_raw_response_wrapperrJrZr"rcr#r#r$__init__QszStepsWithRawResponse.__init__Nr\r]r^rgr#r#r#r$rPsrc@seZdZdddddZdS)r_rrarbcCs&||_t|j|_t|j|_dSrd)rerZasync_to_raw_response_wrapperrJrZrfr#r#r$rg]sz"AsyncStepsWithRawResponse.__init__Nrhr#r#r#r$r_\sr_c@seZdZdddddZdS)r&rrarbcCs"||_t|j|_t|j|_dSrd)rerrJrZrfr#r#r$rgisz#StepsWithStreamingResponse.__init__Nrhr#r#r#r$r&hsr&c@seZdZdddddZdS)r`rrarbcCs"||_t|j|_t|j|_dSrd)rerrJrZrfr#r#r$rgusz(AsyncStepsWithStreamingResponse.__init__Nrhr#r#r#r$r`tsr`). __future__rtypingrZtyping_extensionsrZhttpxr_typesrrr r r _utilsr r Z_compatrZ _resourcerr _responserrZ paginationrrZ _base_clientrrZtypes.beta.threads.runsrrZ types.beta.threads.runs.run_steprZ(types.beta.threads.runs.run_step_includer__all__rrrr_r&r`r#r#r#r$s.