o TjW8@shddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZmZmZmZmZmZmZdd lmZmZdd lmZmZmZmZmZmZdd l m!Z!dd l"m#Z#m$Z$dd l%m&Z&m'Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-ddl.m/Z/ddl0m1Z1ddgZ2Gddde#Z3Gddde$Z4GdddZ5GdddZ6GdddZ7GdddZ8dS)) annotations)LiteralN)_legacy_response)Items AsyncItemsItemsWithRawResponseAsyncItemsWithRawResponseItemsWithStreamingResponseAsyncItemsWithStreamingResponse)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_transform)Turns AsyncTurnsTurnsWithRawResponseAsyncTurnsWithRawResponseTurnsWithStreamingResponseAsyncTurnsWithStreamingResponse)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)Subagent)subagent_list_params SubagentsAsyncSubagentsc@veZdZed(ddZed)ddZed*d d Zed+d d Zdddedd,ddZ e e e dddedd-d&d'Z dS).r'returnrcC t|jSN)r_clientselfr0|/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/openai/resources/beta/agents/sessions/subagents/subagents.pyitems( zSubagents.itemsrcCr+r,)rr-r.r0r0r1turns,r3zSubagents.turnsSubagentsWithRawResponsecCt|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 )r5r.r0r0r1with_raw_response0zSubagents.with_raw_responseSubagentsWithStreamingResponsecCr6z 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.r0r0r1with_streaming_response:z!Subagents.with_streaming_responseN extra_headers extra_query extra_bodytimeout subagent_idstr session_idr?Headers | Noner@ Query | NonerA Body | NonerB(float | httpx2.Timeout | None | NotGivenr%c Cs`|s td||std|ddi|pi}|jtd||dt||||ddid td S) Retrieves a subagent belonging to this session. See [subagent workflows](https://developers.openai.com/api/docs/guides/agents-api/multi-agent). 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 :Expected a non-empty value for `subagent_id` but received OpenAI-Beta agents=v15/agents/sessions/{session_id}/subagents/{subagent_id}rErC bearer_authTr?r@rArBsecurityoptionscast_to ValueError_getrr$r%r/rCrEr?r@rArBr0r0r1retrieveCs$zSubagents.retrieveafterlimitorderr?r@rArBr] str | Omitr^ int | Omitr_Literal['asc', 'desc'] | OmitSyncCursorPage[Subagent]c Cd|s td|ddi|pi}|jtd|dttt||||t|||dtjddid td S aaLists subagents in a session, including nested and closed subagents. See [subagent workflows](https://developers.openai.com/api/docs/guides/agents-api/multi-agent). 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 rKrMrNz'/agents/sessions/{session_id}/subagents)rE)r]r^r_rQT)r?r@rArBqueryrS)pagerUmodel) rX _get_api_listrr!r%r$rr&SubagentListParams r/rEr]r^r_r?r@rArBr0r0r1listp,% zSubagents.list)r*r)r*r)r*r5)r*r:rCrDrErDr?rFr@rGrArHrBrIr*r%)rErDr]r`r^rar_rbr?rFr@rGrArHrBrIr*rc __name__ __module__ __qualname__rr2r4r8r<rr[rrlr0r0r0r1r'',    1c@r)).r(r*rcCr+r,)rr-r.r0r0r1r2r3zAsyncSubagents.itemsrcCr+r,)rr-r.r0r0r1r4r3zAsyncSubagents.turnsAsyncSubagentsWithRawResponsecCr6r7)rtr.r0r0r1r8r9z AsyncSubagents.with_raw_response#AsyncSubagentsWithStreamingResponsecCr6r;)rur.r0r0r1r<r=z&AsyncSubagents.with_streaming_responseNr>rCrDrEr?rFr@rGrArHrBrIr%c sh|s td||std|ddi|pi}|jtd||dt||||ddid td Id HS) rJrKrLrMrNrOrPrQTrRrTNrWrZr0r0r1r[s& zAsyncSubagents.retriever\r]r`r^rar_rb3AsyncPaginator[Subagent, AsyncCursorPage[Subagent]]c Crdre) rXrirr"r%r$rr&rjrkr0r0r1rlrmzAsyncSubagents.list)r*r)r*r)r*rt)r*rurn)rErDr]r`r^rar_rbr?rFr@rGrArHrBrIr*rvror0r0r0r1r(rsc@2eZdZdddZeddd Zedd d Zd S)r5 subagentsr'r*NonecC&||_t|j|_t|j|_dSr,) _subagentsrto_raw_response_wrapperr[rlr/rxr0r0r1__init__6 z!SubagentsWithRawResponse.__init__r cC t|jjSr,)r r{r2r.r0r0r1r2@ zSubagentsWithRawResponse.itemsrcCrr,)rr{r4r.r0r0r1r4DrzSubagentsWithRawResponse.turnsNrxr'r*ry)r*r )r*rrprqrrr~rr2r4r0r0r0r1r55   r5c@rw)rtrxr(r*rycCrzr,)r{rasync_to_raw_response_wrapperr[rlr}r0r0r1r~Jrz&AsyncSubagentsWithRawResponse.__init__r cCrr,)r r{r2r.r0r0r1r2Trz#AsyncSubagentsWithRawResponse.itemsrcCrr,)rr{r4r.r0r0r1r4Xrz#AsyncSubagentsWithRawResponse.turnsNrxr(r*ry)r*r )r*rrr0r0r0r1rtIrrtc@rw)r:rxr'r*rycC"||_t|j|_t|j|_dSr,)r{rr[rlr}r0r0r1r~^ z'SubagentsWithStreamingResponse.__init__r cCrr,)r r{r2r.r0r0r1r2hrz$SubagentsWithStreamingResponse.itemsrcCrr,)rr{r4r.r0r0r1r4lrz$SubagentsWithStreamingResponse.turnsNr)r*r )r*rrr0r0r0r1r:]rr:c@rw)rurxr(r*rycCrr,)r{r r[rlr}r0r0r1r~rrz,AsyncSubagentsWithStreamingResponse.__init__r cCrr,)r r{r2r.r0r0r1r2|rz)AsyncSubagentsWithStreamingResponse.itemsrcCrr,)rr{r4r.r0r0r1r4rz)AsyncSubagentsWithStreamingResponse.turnsNr)r*r )r*rrr0r0r0r1ruqrru)9 __future__rtyping_extensionsrhttpx2rr2rrr r r r _typesr rrrrrr_utilsrr turns.turnsrrrrrr_compatr _resourcerr _responserr paginationr!r" _base_clientr#r$types.beta.subagentr%types.beta.agents.sessionsr&__all__r'r(r5rtr:rur0r0r0r1s0    $