o Tj 1@s(ddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z m Z mZddlmZmZddlmZdd lmZmZdd lmZmZdd lmZmZdd lmZmZdd l m!Z!ddl"m#Z#ddgZ$GdddeZ%GdddeZ&GdddZ'GdddZ(GdddZ)GdddZ*dS)) annotations)LiteralN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)turn_list_params)TurnTurns AsyncTurnsc@ZeZdZed"ddZed#ddZddded d$ddZeeedddedd%d d!Z dS)&rreturnTurnsWithRawResponsecCt|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#n/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/openai/resources/beta/agents/sessions/turns.pywith_raw_responsezTurns.with_raw_responseTurnsWithStreamingResponsecCrz 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"zTurns.with_streaming_responseN extra_headers extra_query extra_bodytimeoutturn_idstr session_idr,Headers | Noner- Query | Noner. Body | Noner/(float | httpx2.Timeout | None | NotGivenrc Cs`|s td||std|ddi|pi}|jtd||dt||||ddid td S) 1Retrieves a turn's current status, timestamps, usage, and error. Returns 404 if the turn does not belong to the session. See [session turns](https://developers.openai.com/api/docs/guides/agents-api/sessions/manage#inspect-session-turns). 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 9Expected a non-empty value for `session_id` but received 6Expected a non-empty value for `turn_id` but received OpenAI-Beta agents=v1-/agents/sessions/{session_id}/turns/{turn_id}r2r0 bearer_authTr,r-r.r/securityoptionscast_to ValueError_getr rrr"r0r2r,r-r.r/r#r#r$retrieve+s  zTurns.retrieveafterlimitorderr,r-r.r/rJ str | OmitrK int | OmitrLLiteral['asc', 'desc'] | OmitSyncCursorPage[Turn]c Cd|s td|ddi|pi}|jtd|dttt||||t|||dtjddid td S aLists turns by creation time and turn ID. The after cursor is exclusive in the selected order. See [session turns](https://developers.openai.com/api/docs/guides/agents-api/sessions/manage#inspect-session-turns). Args: after: Return resources after this resource ID in the selected order. limit: The maximum number of resources to return, between 1 and 100. Defaults to 20. order: The order in which resources are returned. Defaults to `desc`. - `asc` - Returns resources in ascending order. - `desc` - Returns resources in 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 r8r:r;z#/agents/sessions/{session_id}/turns)r2)rJrKrLr>T)r,r-r.r/queryr@)pagerBmodel) rE _get_api_listr rrrrrTurnListParams r"r2rJrKrLr,r-r.r/r#r#r$listW,& z Turns.list)rr)rr'r0r1r2r1r,r3r-r4r.r5r/r6rr)r2r1rJrMrKrNrLrOr,r3r-r4r.r5r/r6rrP __name__ __module__ __qualname__rr%r)r rHr rYr#r#r#r$r$  0c@r)&rrAsyncTurnsWithRawResponsecCrr )rar!r#r#r$r%r&zAsyncTurns.with_raw_responseAsyncTurnsWithStreamingResponsecCrr()rbr!r#r#r$r)r*z"AsyncTurns.with_streaming_responseNr+r0r1r2r,r3r-r4r.r5r/r6rc sh|s td||std|ddi|pi}|jtd||dt||||ddid td Id HS) r7r8r9r:r;r<r=r>Tr?rANrDrGr#r#r$rHs"  zAsyncTurns.retrieverIrJrMrKrNrLrO+AsyncPaginator[Turn, AsyncCursorPage[Turn]]c CrQrR) rErVr rrrrrrWrXr#r#r$rYrZzAsyncTurns.list)rra)rrbr[)r2r1rJrMrKrNrLrOr,r3r-r4r.r5r/r6rrcr\r#r#r#r$rr`c@eZdZdddZdS) rturnsrrNonecC&||_t|j|_t|j|_dSN)_turnsrto_raw_response_wrapperrHrYr"rer#r#r$__init__ zTurnsWithRawResponse.__init__Nrerrrfr]r^r_rlr#r#r#r$rrc@rd) rarerrrfcCrgrh)rirasync_to_raw_response_wrapperrHrYrkr#r#r$rl"rmz"AsyncTurnsWithRawResponse.__init__Nrerrrfror#r#r#r$ra!rprac@rd) r'rerrrfcC"||_t|j|_t|j|_dSrh)rirrHrYrkr#r#r$rl. z#TurnsWithStreamingResponse.__init__Nrnror#r#r#r$r'-rpr'c@rd) rbrerrrfcCrsrh)rirrHrYrkr#r#r$rl:rtz(AsyncTurnsWithStreamingResponse.__init__Nrrror#r#r#r$rb9rprb)+ __future__rtyping_extensionsrhttpx2r_typesrrrr r r r _utilsr r_compatr _resourcerr _responserr paginationrr _base_clientrrtypes.beta.agents.sessionsrtypes.beta.agents.sessions.turnr__all__rrrrar'rbr#r#r#r$s(   $