a 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 @seZdZeddddZeddddZddded d d d d d d dddddZeeeedddedd d ddddd d d ddd ddZdS)rStepsWithRawResponsereturncCst|SN)rselfra/var/www/ai-form-bot/venv/lib/python3.9/site-packages/openai/resources/beta/threads/runs/steps.pywith_raw_responseszSteps.with_raw_responseStepsWithStreamingResponsecCst|Sr)r"rrrr with_streaming_responseszSteps.with_streaming_responseN extra_headers extra_query extra_bodytimeoutstrHeaders | None Query | None Body | None'float | httpx.Timeout | None | NotGivenrstep_id thread_idrun_idr%r&r'r(rcCst|std||s$td||s6td|ddi|pBi}|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$optionsZcast_to ValueError_getrrrr/r0r1r%r&r'r(rrr retrieve#szSteps.retrieveafterbeforelimitorderr%r&r'r(str | NotGivenint | NotGiven!Literal['asc', 'desc'] | NotGivenzSyncCursorPage[RunStep] r1r0rCrDrErFr%r&r'r(rc Csx|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, 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 r3r4r6r7r8r9z/steps)rCrDrErF)r%r&r'r(query)pager<model)r> _get_api_listrrrr rStepListParams rr1r0rCrDrErFr%r&r'r(rrr listKs0,z Steps.list __name__ __module__ __qualname__r r!r#rrArRrrrr rs$  -c @seZdZeddddZeddddZddded d d d d d d dddddZeeeedddedd d ddddd d d ddd ddZdS)rAsyncStepsWithRawResponsercCst|Sr)rWrrrr r!szAsyncSteps.with_raw_responseAsyncStepsWithStreamingResponsecCst|Sr)rXrrrr r#sz"AsyncSteps.with_streaming_responseNr$r)r*r+r,r-rr.csz|std||s$td||s6td|ddi|pBi}|jd|d|d|t||||d td Id HS) r2r3r4r5r6r7r8r9r:r$r;Nr=r@rrr rAszAsyncSteps.retrieverBrGrHrIz1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]rJc Csx|std||s$td|ddi|p0i}|jd|d|dttt||| | t||||dtjd td SrK)r>rOrrrr rrPrQrrr rRs0,zAsyncSteps.listrSrrrr rs$  -c@seZdZdddddZdS)rrNonestepsrcCs&||_t|j|_t|j|_dSr)_stepsrZto_raw_response_wrapperrArRrr[rrr __init__ szStepsWithRawResponse.__init__NrTrUrVr^rrrr r src@seZdZdddddZdS)rWrrYrZcCs&||_t|j|_t|j|_dSr)r\rZasync_to_raw_response_wrapperrArRr]rrr r^sz"AsyncStepsWithRawResponse.__init__Nr_rrrr rWsrWc@seZdZdddddZdS)r"rrYrZcCs"||_t|j|_t|j|_dSr)r\rrArRr]rrr r^#sz#StepsWithStreamingResponse.__init__Nr_rrrr r""sr"c@seZdZdddddZdS)rXrrYrZcCs"||_t|j|_t|j|_dSr)r\rrArRr]rrr r^/sz(AsyncStepsWithStreamingResponse.__init__Nr_rrrr rX.srX)( __future__rtyping_extensionsrZhttpxr_typesrrrr r Z_utilsr _compatr Z _resourcer r _responserrZ paginationrrZ _base_clientrrZtypes.beta.threads.runsrZ types.beta.threads.runs.run_stepr__all__rrrrWr"rXrrrr s&       xx