2h`x8SSKJr SSKrSSKJr SSKJrJrJrJ r J r J r J r J r SSKJrJrJr SSKJr SSKJrJrJr SS KJrJrJrJrJrJrJrJ r J!r!J"r"J#r#J$r$ S S K%J&r& S S KJ'r'J(r(J)r) S SK*J+r+J,r,J-r- S SK.J/r/ S SK0J1r1J2r2 SSK3J4r4J5r5J6r6J7r7J8r8J9r9J:r: S SK;JJ?r?J@r@JArA S SKBJCrCJDrD S SKEJFrF S SKGJHrI S SKJJKrL "SS\\45rM"SS\\45rN"SS\\45rO"SS \\45rP"S!S"\\45rQ"S#S$5rRS'S%jrSS(S&jrTg))) annotationsN) TracebackType) TYPE_CHECKINGAnyGenericCallableIterable Awaitable AsyncIteratorcast)SelfIterator assert_never) from_json)ParsedChoiceSnapshotParsedChatCompletionSnapshot#ParsedChatCompletionMessageSnapshot) ChunkEventContentDoneEventRefusalDoneEventContentDeltaEventRefusalDeltaEventLogprobsContentDoneEventLogprobsRefusalDoneEventChatCompletionStreamEventLogprobsContentDeltaEventLogprobsRefusalDeltaEvent"FunctionToolCallArgumentsDoneEvent#FunctionToolCallArgumentsDeltaEvent)accumulate_delta) NOT_GIVENIncExNotGiven)is_givenconsume_sync_iteratorconsume_async_iterator) model_dump)buildconstruct_type)ResponseFormatThas_parseable_inputmaybe_parse_contentparse_chat_completionget_input_tool_by_namesolve_response_format_tparse_function_tool_arguments)Stream AsyncStream)ChatCompletionChunkParsedChatCompletionChatCompletionToolParam)LengthFinishReasonErrorContentFilterFinishReasonError)ChoiceLogprobs)Choice)ResponseFormatc\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr \ SS j5rSS jrS rg)ChatCompletionStream/Wrapper over the Chat Completions streaming API that adds helpful events such as `content.done`, supports automatically parsing responses & tool calls and accumulates a `ChatCompletion` object from each individual chunk. https://platform.openai.com/docs/api-reference/streaming cxXlURUlUR5Ul[ X#S9UlgNresponse_format input_tools _raw_streamresponse _response __stream__ _iteratorChatCompletionStreamState_stateself raw_streamrFrGs ^/var/www/auris/envauris/lib/python3.13/site-packages/openai/lib/streaming/chat/_completions.py__init__ChatCompletionStream.__init__81&#,,*/i c6URR5$N)rM__next__rQs rSrZChatCompletionStream.__next__Ds~~&&((rWc#:# URHnUv M g7frYrMrQitems rS__iter__ChatCompletionStream.__iter__GsNNDJ#scU$rYr[s rS __enter__ChatCompletionStream.__enter__Ks rWc$UR5 grYcloserQexc_typeexcexc_tbs rS__exit__ChatCompletionStream.__exit__Ns rWc8URR5 gzr Close the response and release the connection. Automatically called if the response body is read to completion. N)rKrir[s rSriChatCompletionStream.closeVs rWcVUR5 URR5$).Waits until the stream has been read to completion and returns the accumulated `ParsedChatCompletion` object. If you passed a class type to `.stream()`, the `completion.choices[0].message.parsed` property will be the content deserialised into that class, if there was any content returned by the API.  until_donerOget_final_completionr[s rSrw)ChatCompletionStream.get_final_completion^s! {{//11rWc[U5 U$)*Blocks until the stream has been consumed.)r(r[s rSrvChatCompletionStream.until_doneisd# rWc.URR$rYrOcurrent_completion_snapshotr[s rSr~0ChatCompletionStream.current_completion_snapshotn{{666rWc## URH=n[U5(dMURRU5nUHnUv M M? g7frYrI$_is_valid_chat_completion_chunk_weakrO handle_chunkrQ sse_eventevents_to_fireevents rSrLChatCompletionStream.__stream__rsF))I7 BB![[55i@N' ( *sAArMrIrKrON)rRzStream[ChatCompletionChunk]rF6type[ResponseFormatT] | ResponseFormatParam | NotGivenrG,Iterable[ChatCompletionToolParam] | NotGivenreturnNonerz*ChatCompletionStreamEvent[ResponseFormatT])rz4Iterator[ChatCompletionStreamEvent[ResponseFormatT]]rr rkztype[BaseException] | NonerlzBaseException | NonermzTracebackType | Nonerrrrrz%ParsedChatCompletion[ResponseFormatT]rr)__name__ __module__ __qualname____firstlineno____doc__rTrZrarernrirwrvpropertyr~rL__static_attributes__rdrWrSr@r@/s j0 jP j B j  j),"%    2 77rWr@cV\rSrSrSrSSjrS SjrS SjrSrg) ChatCompletionStreamManager{a"Context manager over a `ChatCompletionStream` that is returned by `.stream()`. This context manager ensures the response cannot be leaked if you don't read the stream to completion. Usage: ```py with client.chat.completions.stream(...) as stream: for event in stream: ... ``` c6SUlXlX lX0lgrY)$_ChatCompletionStreamManager__stream)_ChatCompletionStreamManager__api_request-_ChatCompletionStreamManager__response_format)_ChatCompletionStreamManager__input_toolsrQ api_requestrFrGs rSrT$ChatCompletionStreamManager.__init__sGK (!0(rWcUR5n[UURURS9UlUR$N)rRrFrG)rr@rrrrQrRs rSre%ChatCompletionStreamManager.__enter__s='') ,! 22**  }}rWcTURbURR5 ggrY)rrirjs rSrn$ChatCompletionStreamManager.__exit__s# == $ MM   ! %rW __api_request __input_tools__response_format__streamN)rz)Callable[[], Stream[ChatCompletionChunk]]rFrrGrrr)rz%ChatCompletionStream[ResponseFormatT]r) rrrrrrTrernrrdrWrSrr{sd  )> )P ) B )  ) ","""% "  "rWrc\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr \ SS j5rSS jrS rg)AsyncChatCompletionStreamrBcxXlURUlUR5Ul[ X#S9UlgrDrHrPs rSrT"AsyncChatCompletionStream.__init__rVrWcR# URR5IShvN $N7frY)rM __anext__r[s rSr#AsyncChatCompletionStream.__anext__s^^--////s '%'cJ# URShvN nU7v MN g7frYr^r_s rS __aiter__#AsyncChatCompletionStream.__aiter__s.. $J .s #!!#!#c# U$7frYrdr[s rS __aenter__$AsyncChatCompletionStream.__aenter__s  sc@# UR5IShvN gN7frYrhrjs rS __aexit__#AsyncChatCompletionStream.__aexit__s jjls cT# URR5IShvN gN7frq)rKacloser[s rSriAsyncChatCompletionStream.closes nn##%%%s (&(cr# UR5IShvN URR5$N7f)rtNrur[s rSrw.AsyncChatCompletionStream.get_final_completions/oo{{//11 s 757c8# [U5IShvN U$N7f)rzN)r)r[s rSrv$AsyncChatCompletionStream.until_dones$T***  +s c.URR$rYr}r[s rSr~5AsyncChatCompletionStream.current_completion_snapshotrrWc# URShvN n[U5(dMURRU5nUHnU7v M MFNA g7frYrrs rSrL$AsyncChatCompletionStream.__stream__sN#// )7 BB![[55i@N' (  /s% AAAA>AAArN)rRz AsyncStream[ChatCompletionChunk]rFrrGrrrr)rz9AsyncIterator[ChatCompletionStreamEvent[ResponseFormatT]]rrrrr)rrrrrrTrrrrrirwrvrr~rLrrdrWrSrrs j5 jP j B j  j0,"%   & 2 77rWrcV\rSrSrSrSSjrS SjrS SjrSrg) AsyncChatCompletionStreamManagera-Context manager over a `AsyncChatCompletionStream` that is returned by `.stream()`. This context manager ensures the response cannot be leaked if you don't read the stream to completion. Usage: ```py async with client.chat.completions.stream(...) as stream: for event in stream: ... ``` c6SUlXlX lX0lgrY))_AsyncChatCompletionStreamManager__stream._AsyncChatCompletionStreamManager__api_request2_AsyncChatCompletionStreamManager__response_format._AsyncChatCompletionStreamManager__input_toolsrs rSrT)AsyncChatCompletionStreamManager.__init__sLP (!0(rWc# URIShvN n[UURURS9UlUR$N47fr)rrrrrrs rSr+AsyncChatCompletionStreamManager.__aenter__sE--- 1! 22**  }}.sA A5A cp# URb#URR5IShvN ggN7frY)rrirjs rSr*AsyncChatCompletionStreamManager.__aexit__s/ == $--%%' ' ' % 's +646rN)rz+Awaitable[AsyncStream[ChatCompletionChunk]]rFrrGrrr)rz*AsyncChatCompletionStream[ResponseFormatT]r) rrrrrrTrrrrdrWrSrrsd  )@ )P ) B )  ) (,("(% (  (rWrc\rSrSrSr\\S.S SjjrSSjr\SSj5r SSjr SSjr SS jr SS jr S rg )rNi%a#Helper class for manually accumulating `ChatCompletionChunk`s into a final `ChatCompletion` object. This is useful in cases where you can't always use the `.stream()` method, e.g. ```py from openai.lib.streaming.chat import ChatCompletionStreamState state = ChatCompletionStreamState() stream = client.chat.completions.create(..., stream=True) for chunk in response: state.handle_chunk(chunk) # can also access the accumulated `ChatCompletion` mid-stream state.current_completion_snapshot print(state.get_final_completion()) ``` )rGrFcSUl/Ul[U5(aUVs/sHo3PM snO/UlX l[ R "U5(aX lg[Ulgs snfrY) 7_ChatCompletionStreamState__current_completion_snapshot/_ChatCompletionStreamState__choice_event_statesr' _input_tools_response_formatinspectisclassr$_rich_response_format)rQrGrFtools rSrT"ChatCompletionStreamState.__init__:sb SW*=?">F{>S>Sk:kdTk:Y[ /IPYhIiIio"ox";s A,cT[URURURS9$)zParse the final completion object. Note this does not provide any guarantees that the stream has actually finished, you must only call this method when the stream is finished. )chat_completionrFrG)r1r~rrr[s rSrw.ChatCompletionStreamState.get_final_completionGs, % << 66))  rWc8URceUR$rY)rr[s rSr~5ChatCompletionStreamState.current_completion_snapshotSs 11===111rWcbURU5UlURUURS9$)zTAccumulate a new chunk into the snapshot and returns an iterable of events to yield.)chunkcompletion_snapshot)_accumulate_chunkr _build_events)rQrs rSr&ChatCompletionStreamState.handle_chunkXs9-1-C-CE-J*!! $ B B"  rWcURUR$![a3 [URS9nURR U5 Us$f=f)N)rG)rindex IndexErrorChoiceEventStaterappend)rQchoice choice_states rS_get_choice_state+ChatCompletionStreamState._get_choice_stateasU --fll; ; +8I8IJL  & & - -l ;  s:AAc URnUc [U5$URGH8nURURnURR =(d /n[ [[[[[ S[UR[ [S[URR =(d /5VVs0sH upgUSSS00_M snnS.5S95[ SURR555S95Ul[U5HupURR =(d /Un U RS:Xa9U RS:XdeU R R"U R lMp[$(dM}['U 5 M UR.(agUR.Ul[1UR2UR4S 9(a3UR.S :Xa [7US 9eUR.S:Xa [95eURR:(aURR<(dz[?UR@5(a`URR:RC5(a7[E[GURR:S5SS9URl$URR =(d /GHn URR =(d /U Rn U RS:Xa[KUR4U R RLS9n U (a~U ROS05ROS5(aVU R RP(a9[E[GU R RPS5SS9U R lMMMM[$(dM['U 5 GM URRcGMURRc?[U[VURRR:URRR<S9Ul)GM=URRR:(aaURRR:c/URRlURRR:RYURRR:5 URRR<(dGMURRR<c/URRlURRR<RYURRR<5 GM; URZUl-UR\Ul.U$s snnf![(ah [ [*[[*0URSS1S 9ES URR50ES95nURR-U5 GNJf=f)Nzdict[object, object]Tfunctionparsed_arguments)parsed tool_calls)excludetype_valuedelta exclude_unsetrmessagerElength) completioncontent_filterzutf-8) partial_mode)rGnamestrict)contentrefusal)/r$_convert_initial_chunk_into_snapshotchoicesrrrr rr,r"r*r% enumeraterto_dicttyperrrrrrr finish_reasonr/rrr:r;r rr'rlstriprbytesrr2r get argumentslogprobsr+r<extendusagesystem_fingerprint)rQrrrchoice_snapshotprevious_tool_callsidx_ tool_index prev_toolnew_tooltool_call_chunktool_call_snapshot input_tools rSr+ChatCompletionStreamState._accumulate_chunkis"@@  &7> >mmF7 D"5"="=fll"K&5&=&=&H&H&NB#*.7"A. 6 *$3$;$;-1(-6:?HH_H_HjHjHpnp>q;.>qFC14jCUW[B\5]0]>q;.)* -& !"(!!79M9M9OP++'@.77J-K)J / 7 7 B B Hb*UH ~~3'}} :::=F=O=O=`=`)):&$Y/.L*##060D0D-&t7L7LZ^ZkZkl++x76ATUU++/??<>> ''//'//77T7788#++33::<<1:/11997C!%2''. $*<<#:#:#@b#@&5&=&=&H&H&NBP_PePe%f"%**j8!7$($5$5>xHH.77AAGP!"4"="="G"GQ)-H*33DBI##] !34%$A(*"++3/4& & 7 7 & 7 70O, ..*33;;C?AO44<'0088??@W@WX...*33;;C?AO44<'0088??@W@WXq$t%*KK!161I1I.""O;.. D"&("2$//dWI/V%v||';';'= #$++22?C Ds,BV V,CV&VVA.X?Xc/nUR[[SXS95 URGHnUR U5nURUR nUR RbsURRb\UR[[SUR RURRURRS95 UR Rb^URRbGUR[[SUR RURRS95 UR R(GaURRnUceUR RHnXxR n U RS:XaURceUR[[ SU RR"UR U RR$U RR&URR$=(d S S 95 M[((dM[+U 5 M UR,GbUR,bUR,R(abUR,R(aGUR[[.S UR,RUR,RS 95 UR,R(abUR,R(aGUR[[0S UR,RUR,RS95 UR3UR5UUUR6S95 GM U$)Nr)rrsnapshotz content.delta)rrr)rz refusal.delta)rrr)rz#tool_calls.function.arguments.delta)rr rrrarguments_deltazlogprobs.content.delta)rr r)zlogprobs.refusal.delta)rrr)) choice_chunkrrF)rr+rrrrrr rrrrrrrrr r rrrrrrrrget_done_eventsr) rQrrrrrrrtool_call_delta tool_calls rSr'ChatCompletionStreamState._build_eventss LN *7% V mmF11&9L199&,,GO||##/O4K4K4S4S4_%%),$ll22!0!8!8!@!@.66== ||##/O4K4K4S4S4_%%),$ll22!0!8!8!@!@ ||&&&,44?? !---'-||'>'>O *+@+@ AI ~~3.77CCC&--! C%J%.%7%7%<%<&5&;&;*3*<*<*F*F1:1C1C1T1T0?0H0H0R0R0XVX '$Y/#(?&*/G/G/S??**/G/G/O/O"))5!9$*OO$;$;%4%=%=%E%E ??**/G/G/O/O"))5!9$*OO$;$;%4%=%=%E%E   ! !,,!'$3$($9$9- K$ZrW)__choice_event_states__current_completion_snapshotrrrN)rGrrFrrrrr)rr7rz4Iterable[ChatCompletionStreamEvent[ResponseFormatT]])r ChoiceChunkrrrr7rr)rr7rrr0list[ChatCompletionStreamEvent[ResponseFormatT]])rrrrrr$rTrwrr~rrrrrrdrWrSrNrN%s.ENR[ yB yP y  y  22  C#JY#Y: Y : YrWrNch\rSrSrSSjrS SjrS SjrS SjrSrg) riJctXlSUlSUlSUlSUl[ 5UlSUlg)NF)r _content_done _refusal_done_logprobs_content_done_logprobs_refusal_doneset_done_tool_calls*_ChoiceEventState__current_tool_call_index)rQrGs rSrTChoiceEventState.__init__Ks:'""&+#&+#*-%59&rWc/nUR(a`URURX#S95 URb5URUR;aUR UUURS9 UR R=(d /HtnURUR:waFURURX#S95 URbUR UUURS9 URUlMv U$)N)rrF)rrr!) rr_content_done_eventsr>r=_add_tool_done_eventrrr)rQr,rrFrr/s rSr- ChoiceEventState.get_done_eventsUsLN  ( (  ! !))/)k  ..:22$:O:OO))#1$3#==* &++66<".>P > : >@$-I$-. $-  $-  $-rWrc $UR5n[SUS5nURH>n0URSS1S9ESURR50EX#R 'M@ [[ [[ SS0UESS 0ES 95$) Nz list[object]rTrrrrobjectzchat.completionr)rr rr*rrrr,)rdatarrs rSrrs ==?D>4 ?3G--! dWIF! v||++-!   $.$d+   rWc URS:H$)Nzchat.completion.chunk)rL)rs rSrrs   6 66rWr4)rr7rbool)U __future__rrtypesrtypingrrrrr r r r typing_extensionsr rrjiterr_typesrrr_eventsrrrrrrrrrrrr _deltasr"r$r%r&_utilsr'r(r)_compatr*_modelsr+r,_parsingr.r/r0r1r2r3r4 _streamingr5r6 types.chatr7r8r9 _exceptionsr:r;types.chat.chat_completionr< types.chat.chat_completion_chunkr=r3#types.chat.completion_create_paramsr>ResponseFormatParamr@rrrrNrrrrdrWrSrcs"bbb::kk    '11NN"-/]]S9FYI7?3IX,"'/":,"^I 8IX,(w'?,(^b 8bJ X-X-v.7rW