+ ~jRz^RIHt^RIHtHt^RIHt^RIt^RIH t ^RI H t H t H t HtHtHtHt^RIHtHt^RIHt^R IHtHt^R IHtHt^R IHtHt^R I H!t!H"t"^R I#H$t$H%t%^RI&H't'^RI(H)t)^RI*H+t+RR.t,!RR]4t-!RR]4t.!RR4t/!RR4t0!RR4t1!RR4t2R#)) annotations)Anycast)LiteralN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncConversationCursorPageAsyncConversationCursorPage)AsyncPaginatormake_request_options)thread_list_paramsthread_list_items_params) ChatKitThread)ThreadDeleteResponse)DataThreads AsyncThreadsc]tRt^t]RRl4t]RRl4tRRRRRRR ]/R R lltR ] R ] R] R] R] RRRRRRR ]/ RRllt RRRRRRR ]/RRllt R ] R ] R] R] RRRRRRR ]/RRllt Rt R#)rcV^8dQhRR/#)returnThreadsWithRawResponse)formats"z/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/openai/resources/beta/chatkit/threads.py __annotate__Threads.__annotate__s,,#9,c \V4#z 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%selfs&r(with_raw_responseThreads.with_raw_responses&d++r+cV^8dQhRR/#)r#r$ThreadsWithStreamingResponser&)r's"r(r)r*&s22)E2r+c \V4#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 )r3r.s&r(with_streaming_responseThreads.with_streaming_response%s,D11r+ extra_headersN extra_query extra_bodytimeoutc 0V^8dQhRRRRRRRRR R R R /# r# thread_idstrr8Headers | Noner9 Query | Noner: Body | Noner;'float | httpx.Timeout | None | NotGivenr$rr&)r's"r(r)r*.F$ $ $ & $ "$  $ 9$  $ r+c  V'g\RV: 24hRR/T;'g/CpVP\RVR7\VVVVRR/R7\R 7#) ( Retrieve a ChatKit thread by its identifier. 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 OpenAI-Betachatkit_beta=v1/chatkit/threads/{thread_id}r> bearer_authTr8r9r:r;securityoptionscast_to ValueError_getrrrr/r>r8r9r:r;s&&$$$$r(retrieveThreads.retrieve.sv.WXaWdef f&(9Sm>Q>QrS yy 8I N(+'%'. "  r+afterbeforelimitorderuserc@V^8dQhRRRRRRRRRRR R R R R RRRRR/ #)r#rX str | OmitrYrZ int | Omitr[Literal['asc', 'desc'] | Omitr\r8r@r9rAr:rBr;rCr$z)SyncConversationCursorPage[ChatKitThread]r&)r's"r(r)r*Tsp> > >  >  > - > > &> ">  > 9>  3> r+c  RR/T;'g/CpVPR\\,\VVVV \ RVRVRVRVRV/\ P 4R R /R 7\R 7# a List ChatKit threads with optional pagination and user filters. Args: after: List items created after this thread item ID. Defaults to null for the first page. before: List items created before this thread item ID. Defaults to null for the newest results. limit: Maximum number of thread items to return. Defaults to 20. order: Sort order for results by creation time. Defaults to `desc`. user: Filter threads that belong to this user identifier. Defaults to null to return all users. 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 rHrIz/chatkit/threadsrXrYrZr[r\rLTr8r9r:r;queryrNpagerPmodel) _get_api_listrrrrrThreadListParams r/rXrYrZr[r\r8r9r:r;s &$$$$$$$$$r(list Threads.listTsP'(9Sm>Q>QrS !! +M:(+'%% & '77 (." )"  r+c 0V^8dQhRRRRRRRRR R R R /# r#r>r?r8r@r9rAr:rBr;rCr$rr&)r's"r(r)r*F$ $ $ & $ "$  $ 9$  $ r+c  V'g\RV: 24hRR/T;'g/CpVP\RVR7\VVVVRR/R7\R 7#) @ Delete a ChatKit thread along with its items and stored attachments. 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 rGrHrIrJrKrLTrMrOrS_deleterrrrUs&&$$$$r(deleteThreads.deletesv.WXaWdef f&(9Sm>Q>QrS || 8I N(+'%'. )  r+c@V^8dQhRRRRRRRRRR R R R R RRRRRR/ #)r#r>r?rXr^rYrZr_r[r`r8r@r9rAr:rBr;rCr$z SyncConversationCursorPage[Data]r&)r's"r(r)r*sn< < <  <  <  < -< &< "<  < 9<  *< r+c 4V'g\RV: 24hRR/T;'g/CpVP\RVR7\\,\ VVVV \ RVRVRVR V/\P4R R /R 7\\\4R 7#a~ List items that belong to a ChatKit thread. Args: after: List items created after this thread item ID. Defaults to null for the first page. before: List items created before this thread item ID. Defaults to null for the newest results. limit: Maximum number of thread items to return. Defaults to 20. order: Sort order for results by creation time. Defaults to `desc`. 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 rGrHrIz"/chatkit/threads/{thread_id}/itemsrKrXrYrZr[rLTrcre) rSrhrrrrrrThreadListItemsParamsrr r/r>rXrYrZr[r8r9r:r;s &&$$$$$$$$r( list_itemsThreads.list_itemssJWXaWdef f&(9Sm>Q>QrS !! >) T+D1(+'%% &  -BB(. sD/'"  r+r&__name__ __module__ __qualname____firstlineno__rr0r6rrVr rkrtr{__static_attributes__r&r+r(rrsB,,22$ )- $ %)$ #'$  !> " > ! > 04 >  > )-> %)> #'>  @$ )- $ %)$ #'$ 1r+c \V4#r-)rr.s&r(r0AsyncThreads.with_raw_responses+400r+cV^8dQhRR/#)r#r$!AsyncThreadsWithStreamingResponser&)r's"r(r)rs77)J7r+c \V4#r5)rr.s&r(r6$AsyncThreads.with_streaming_responses166r+r8Nr9r:r;c 0V^8dQhRRRRRRRRR R R R /#r=r&)r's"r(r)r rDr+c "V'g\RV: 24hRR/T;'g/CpVP\RVR7\VVVVRR/R7\R 7GR jxL #L5i) rFrGrHrIrJrKrLTrMrONrRrUs&&$$$$r(rVAsyncThreads.retrieve s.WXaWdef f&(9Sm>Q>QrS YY 8I N(+'%'. "    #A':A' A%!A'rXrYrZr[r\c@V^8dQhRRRRRRRRRRR R R R R RRRRR/ #)r#rXr^rYrZr_r[r`r\r8r@r9rAr:rBr;rCr$zIAsyncPaginator[ChatKitThread, AsyncConversationCursorPage[ChatKitThread]]r&)r's"r(r)r3sq> > >  >  > - > > &> ">  > 9>  S> r+c  RR/T;'g/CpVPR\\,\VVVV \ RVRVRVRVRV/\ P 4R R /R 7\R 7#rb)rhrrrrrrirjs &$$$$$$$$$r(rkAsyncThreads.list3sP'(9Sm>Q>QrS !! ,];(+'%% & '77 (." )"  r+c 0V^8dQhRRRRRRRRR R R R /#rnr&)r's"r(r)rsror+c "V'g\RV: 24hRR/T;'g/CpVP\RVR7\VVVVRR/R7\R 7GR jxL #L5i) rqrGrHrIrJrKrLTrMrONrrrUs&&$$$$r(rtAsyncThreads.deletess.WXaWdef f&(9Sm>Q>QrS \\ 8I N(+'%'. )"    rc@V^8dQhRRRRRRRRRR R R R R RRRRRR/ #)r#r>r?rXr^rYrZr_r[r`r8r@r9rAr:rBr;rCr$z7AsyncPaginator[Data, AsyncConversationCursorPage[Data]]r&)r's"r(r)rso< < <  <  <  < -< &< "<  < 9<  A< r+c 4V'g\RV: 24hRR/T;'g/CpVP\RVR7\\,\ VVVV \ RVRVRVR V/\P4R R /R 7\\\4R 7#rx) rSrhrrrrrrryrrrzs &&$$$$$$$$r(r{AsyncThreads.list_itemssJWXaWdef f&(9Sm>Q>QrS !! >) T,T2(+'%% &  -BB(. sD/'"  r+r&r}r&r+r(r r sB1177$ )- $ %)$ #'$  !> " > ! > 04 >  > )-> %)> #'>  @$ )- $ %)$ #'$ > NN  +BB    r+rrtrkr{rVNr~rrrrrr&r+r(r%r%   r+r%c"]tRtRtRRltRtR#)ric V^8dQhRRRR/#r#rr r$rr&)r's"r(r)(AsyncThreadsWithRawResponse.__annotate__    r+c :Wn\P!VP4Vn\P!VP4Vn\P!VP 4Vn\P!VP 4VnR#r)rrasync_to_raw_response_wrapperrVrkrtr{rs&&r(r$AsyncThreadsWithRawResponse.__init__su (FF     %BB LL  'DD NN  +HH    r+rNrr&r+r(rrrr+rc"]tRtRtRRltRtR#)r3ic V^8dQhRRRR/#rr&)r's"r(r))ThreadsWithStreamingResponse.__annotate__rr+c Wn\VP4Vn\VP4Vn\VP4Vn\VP 4VnR#r)rrrVrkrtr{rs&&r(r%ThreadsWithStreamingResponse.__init__s] 4     1 LL  3 NN  7    r+rNrr&r+r(r3r3rr+r3c"]tRtRtRRltRtR#)ric V^8dQhRRRR/#rr&)r's"r(r).AsyncThreadsWithStreamingResponse.__annotate__rr+c Wn\VP4Vn\VP4Vn\VP4Vn\VP 4VnR#r)rrrVrkrtr{rs&&r(r*AsyncThreadsWithStreamingResponse.__init__s] :     7 LL  9 NN  =    r+rNrr&r+r(rrrr+r)3 __future__rtypingrrtyping_extensionsrhttpxr_typesrr r r r r r_utilsrr_compatr _resourcerr _responserr paginationrr _base_clientrrtypes.beta.chatkitrr!types.beta.chatkit.chatkit_threadr)types.beta.chatkit.thread_delete_responser+types.beta.chatkit.chatkit_thread_item_listr__all__rr r%rr3rr&r+r(rs#% !LLL5';ZRAO?N@ n %\ o\ ~\ #\ ~  $  $  $  r+