ޠjx4SSKJr 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 SSK3J4r4J5r5J6r6J7r7J8r8J9r9 S SK:J;r;Jr>J?r?J@r@ S SKAJBrBJCrC S SKDJErE S SKFJGrH S SKIJJrK "SS\\45rL"SS\\45rM"SS\\45rN"SS \\45rO"S!S"\\45rP"S#S$5rQS'S%jrRS(S&jrSg))) annotationsN) TracebackType) TYPE_CHECKINGAnyGenericCallableIterable Awaitable AsyncIteratorcast)SelfIterator assert_never) from_json)ParsedChoiceSnapshotParsedChatCompletionSnapshot#ParsedChatCompletionMessageSnapshot) ChunkEventContentDoneEventRefusalDoneEventContentDeltaEventRefusalDeltaEventLogprobsContentDoneEventLogprobsRefusalDoneEventChatCompletionStreamEventLogprobsContentDeltaEventLogprobsRefusalDeltaEvent"FunctionToolCallArgumentsDoneEvent#FunctionToolCallArgumentsDeltaEvent)accumulate_delta)OmitIncExomit)is_givenconsume_sync_iteratorconsume_async_iterator) model_dump)buildconstruct_type)ResponseFormatThas_parseable_inputmaybe_parse_contentparse_chat_completionget_input_tool_by_nameparse_function_tool_arguments)Stream AsyncStream)ChatCompletionChunkParsedChatCompletionChatCompletionToolUnionParam)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_streamrErFs `/var/www/html/gaurav/venv/lib/python3.13/site-packages/openai/lib/streaming/chat/_completions.py__init__ChatCompletionStream.__init__71&#,,*/i c6URR5$N)rL__next__rPs rRrYChatCompletionStream.__next__Cs~~&&((rVc#:# URHnUv M g7frXrLrPitems rR__iter__ChatCompletionStream.__iter__FsNNDJ#scU$rXrZs rR __enter__ChatCompletionStream.__enter__Js rVc$UR5 grXcloserPexc_typeexcexc_tbs rR__exit__ChatCompletionStream.__exit__Ms rVc8URR5 gzr Close the response and release the connection. Automatically called if the response body is read to completion. N)rJrhrZs rRrhChatCompletionStream.closeUs rVcVUR5 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_donerNget_final_completionrZs rRrv)ChatCompletionStream.get_final_completion]s! {{//11rVc[U5 U$)*Blocks until the stream has been consumed.)r(rZs rRruChatCompletionStream.until_donehsd# rVc.URR$rXrNcurrent_completion_snapshotrZs rRr}0ChatCompletionStream.current_completion_snapshotm{{666rVc## URH=n[U5(dMURRU5nUHnUv M M? g7frXrH$_is_valid_chat_completion_chunk_weakrN handle_chunkrP sse_eventevents_to_fireevents rRrKChatCompletionStream.__stream__qsF))I7 BB![[55i@N' ( *sAArLrHrJrNN)rQzStream[ChatCompletionChunk]rE2type[ResponseFormatT] | ResponseFormatParam | OmitrF-Iterable[ChatCompletionToolUnionParam] | OmitreturnNonerz*ChatCompletionStreamEvent[ResponseFormatT])rz4Iterator[ChatCompletionStreamEvent[ResponseFormatT]]rr rjztype[BaseException] | NonerkzBaseException | NonerlzTracebackType | Nonerrrrrz%ParsedChatCompletion[ResponseFormatT]rr)__name__ __module__ __qualname____firstlineno____doc__rSrYr`rdrmrhrvrupropertyr}rK__static_attributes__rcrVrRr?r?.s j0 jL j C j  j),"%    2 77rVr?cV\rSrSrSrSSjrS SjrS SjrSrg) ChatCompletionStreamManagerza"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 lX0lgrX)$_ChatCompletionStreamManager__stream)_ChatCompletionStreamManager__api_request-_ChatCompletionStreamManager__response_format)_ChatCompletionStreamManager__input_toolsrP api_requestrErFs rRrS$ChatCompletionStreamManager.__init__sGK (!0(rVcUR5n[UURURS9UlUR$N)rQrErF)rr?rrrrPrQs rRrd%ChatCompletionStreamManager.__enter__s='') ,! 22**  }}rVcTURbURR5 ggrX)rrhris rRrm$ChatCompletionStreamManager.__exit__s# == $ MM   ! %rV __api_request __input_tools__response_format__streamN)rz)Callable[[], Stream[ChatCompletionChunk]]rErrFrrr)rz%ChatCompletionStream[ResponseFormatT]r) rrrrrrSrdrmrrcrVrRrrzsd  )> )L ) C )  ) ","""% "  "rVrc\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr \ SS j5rSS jrS rg)AsyncChatCompletionStreamrAcxXlURUlUR5Ul[ X#S9UlgrCrGrOs rRrS"AsyncChatCompletionStream.__init__rUrVcR# URR5IShvN $N7frX)rL __anext__rZs rRr#AsyncChatCompletionStream.__anext__s^^--////s '%'cJ# URShvN nU7v MN g7frXr]r^s rR __aiter__#AsyncChatCompletionStream.__aiter__s.. $J .s #!!#!#c# U$7frXrcrZs rR __aenter__$AsyncChatCompletionStream.__aenter__s  sc@# UR5IShvN gN7frXrgris rR __aexit__#AsyncChatCompletionStream.__aexit__s jjls cT# URR5IShvN gN7frp)rJacloserZs rRrhAsyncChatCompletionStream.closes nn##%%%s (&(cr# UR5IShvN URR5$N7f)rsNrtrZs rRrv.AsyncChatCompletionStream.get_final_completions/oo{{//11 s 757c8# [U5IShvN U$N7f)ryN)r)rZs rRru$AsyncChatCompletionStream.until_dones$T***  +s c.URR$rXr|rZs rRr}5AsyncChatCompletionStream.current_completion_snapshotrrVc# URShvN n[U5(dMURRU5nUHnU7v M MFNA g7frXrrs rRrK$AsyncChatCompletionStream.__stream__sN#// )7 BB![[55i@N' (  /s% AAAA>AAArN)rQz AsyncStream[ChatCompletionChunk]rErrFrrrr)rz9AsyncIterator[ChatCompletionStreamEvent[ResponseFormatT]]rrrrr)rrrrrrSrrrrrhrvrurr}rKrrcrVrRrrs j5 jL j C j  j0,"%   & 2 77rVrcV\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 lX0lgrX))_AsyncChatCompletionStreamManager__stream._AsyncChatCompletionStreamManager__api_request2_AsyncChatCompletionStreamManager__response_format._AsyncChatCompletionStreamManager__input_toolsrs rRrS)AsyncChatCompletionStreamManager.__init__sLP (!0(rVc# URIShvN n[UURURS9UlUR$N47fr)rrrrrrs rRr+AsyncChatCompletionStreamManager.__aenter__sE--- 1! 22**  }}.sA A5A cp# URb#URR5IShvN ggN7frX)rrhris rRr*AsyncChatCompletionStreamManager.__aexit__s/ == $--%%' ' ' % 's +646rN)rz+Awaitable[AsyncStream[ChatCompletionChunk]]rErrFrrr)rz*AsyncChatCompletionStream[ResponseFormatT]r) rrrrrrSrrrrcrVrRrrsd  )@ )L ) C )  ) (,("(% (  (rVrc\rSrSrSr\\S.S SjjrSSjr\SSj5r SSjr SSjr SS jr SS jr S rg )rMi$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()) ``` )rFrEcSUl/Ul[U5(aUVs/sHo3PM snO/UlX l[ R "U5(aX lg[Ulgs snfrX) 7_ChatCompletionStreamState__current_completion_snapshot/_ChatCompletionStreamState__choice_event_statesr' _input_tools_response_formatinspectisclassr&_rich_response_format)rPrFrEtools rRrS"ChatCompletionStreamState.__init__9sb SW*=?">F{>S>Sk:kdTk:Y[ /EL__UdEeEe/"ko";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_completionrErF)r1r}rrrZs rRrv.ChatCompletionStreamState.get_final_completionFs, % << 66))  rVc8URceUR$rX)rrZs rRr}5ChatCompletionStreamState.current_completion_snapshotRs 11===111rVcbURU5UlURUURS9$)zTAccumulate a new chunk into the snapshot and returns an iterable of events to yield.)chunkcompletion_snapshot)_accumulate_chunkr _build_events)rPrs rRr&ChatCompletionStreamState.handle_chunkWs9-1-C-CE-J*!! $ B B"  rVcURUR$![a3 [URS9nURR U5 Us$f=f)N)rF)rindex IndexErrorChoiceEventStaterappend)rPchoice choice_states rR_get_choice_state+ChatCompletionStreamState._get_choice_state`sU --fll; ; +8I8IJL  & & - -l ;  s:AAc URnUc [U5$URGH7nURURnURR =(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_unsetrmessagerDlength) completioncontent_filterzutf-8) partial_mode)rFnamestrict)contentrefusal)/r$_convert_initial_chunk_into_snapshotchoicesrrrr rr,r"r*r% enumeraterto_dicttyperrrrrrr finish_reasonr/rrr9r:r r r'rlstriprbytesrr2r get argumentslogprobsr+r;extendusagesystem_fingerprint)rPrrrchoice_snapshotprevious_tool_callsidx_ tool_index prev_toolnew_tooltool_call_chunktool_call_snapshot input_tools rRr+ChatCompletionStreamState._accumulate_chunkhs"@@  &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 %V V  A.W?>W?c/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)rr r() choice_chunkrrE)rr+rrrrrr rrrr rrrrr r rrrrrrrrget_done_eventsr) rPrrrrrrrtool_call_delta tool_calls rRr'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$ZrV)__choice_event_states__current_completion_snapshotrrrN)rFrrErrrrr)rr6rz4Iterable[ChatCompletionStreamEvent[ResponseFormatT]])r ChoiceChunkrrrr6rr)rr6rrr0list[ChatCompletionStreamEvent[ResponseFormatT]])rrrrrr&rSrvrr}rrrrrrcrVrRrMrM$s.FJNR pC pL p  p  22  C#JY#Y: Y : YrVrMch\rSrSrSSjrS SjrS SjrS SjrSrg) riIctXlSUlSUlSUlSUl[ 5UlSUlg)NF)r _content_done _refusal_done_logprobs_content_done_logprobs_refusal_doneset_done_tool_calls*_ChoiceEventState__current_tool_call_index)rPrFs rRrSChoiceEventState.__init__Js:'""&+#&+#*-%59&rVc/nUR(a`URURX#S95 URb5URUR;aUR UUURS9 UR R=(d /HtnURUR:waFURURX#S95 URbUR UUURS9 URUlMv U$)N)rrE)rrr ) rr_content_done_eventsr=r<_add_tool_done_eventrrr)rPr+rrErr.s rRr, ChoiceEventState.get_done_eventsTsLN  ( (  ! !))/)k  ..:22$:O:OO))#1$3#==* &++66<".>L > : >@$-I$-. $-  $-  $-rVrc HUR5nURSS5 [SUS5nURH>n0UR SS1S9ESUR R50EX#R 'M@ [[[[SS0UES S 0ES 95$) N obfuscationz list[object]rTrrrrobjectzchat.completionr) rpopr rr*rrrr,)rdatarrs rRrrs ==?DHH]D!>4 ?3G--! dWIF! v||++-!   $.$d+   rVc URS:H$)Nzchat.completion.chunk)rL)rs rRrrs   6 66rVr3)rr6rbool)T __future__rrtypesrtypingrrrrr r r r typing_extensionsr rrjiterr_typesrrr_eventsrrrrrrrrrrrr _deltasr"r$r%r&_utilsr'r(r)_compatr*_modelsr+r,_parsingr.r/r0r1r2r3 _streamingr4r5 types.chatr6r7r8 _exceptionsr9r:types.chat.chat_completionr; types.chat.chat_completion_chunkr<r2#types.chat.completion_create_paramsr=ResponseFormatParamr?rrrrMrrrrcrVrRrds"bbb::kk    '((NN"-/bbS9FYI7?3IX,"'/":,"^I 8IX,(w'?,(^b 8bJ X-X-v07rV