ޠj %SSKJr SSKrSSKrSSKJr SSKJrJrJ r J r SSK J r SSK r SSKJr SSKJrJrJrJrJrJr S S KJrJrJrJr S S KJrJrJrJ r J!r! S S K"J#r# S S K$J%r% S SK&J'r' S SK(J)r)J*r* S SK+J,r, S SK-J.r. S SK/J0r0J1r1J2r2 SSK3J4r4J5r5J6r6J7r7J8r8J9r9 S SK:J;r; S SKJ?r? S SK@JArA S SKBJCrC \(aSSKDJErF SSKGJErH S SKIJJrJJKrK SS/rL\R"\N5rOS\PS'"SS\)5rQ"S S\*5rR"S!S"5rS"S#S$5rT"S%S&5rU"S'S(5rV"S)S*5rW"S+S,5rX"S-S.5rY"S/S05rZ"S1S25r["S3S4\[5r\"S5S6\[5r]"S7S8\[5r^"S9S:\[5r_"S;S<\[5r`"S=S>\[5ra"S?S@\[5rb"SASB5rc"SCSD\c5rd"SESF\c5re"SGSH\c5rf"SISJ\c5rg"SKSL\c5rh"SMSN\c5ri"SOSP\c5rjg)Q) annotationsN) TracebackType) TYPE_CHECKINGAnyIteratorcast) AsyncIterator) BaseModel)Sessions AsyncSessionsSessionsWithRawResponseAsyncSessionsWithRawResponseSessionsWithStreamingResponse"AsyncSessionsWithStreamingResponse) NOT_GIVENQueryHeadersNotGiven)is_azure_clientmaybe_transformstrip_not_givenasync_maybe_transformis_async_azure_client)cached_property)normalize_httpx_url)construct_type_unchecked)SyncAPIResourceAsyncAPIResource) OpenAIError)_merge_mappings)session_update_event_paramresponse_create_event_param"transcription_session_update_param)TranscriptionSessionsAsyncTranscriptionSessions$TranscriptionSessionsWithRawResponse)AsyncTranscriptionSessionsWithRawResponse*TranscriptionSessionsWithStreamingResponse/AsyncTranscriptionSessionsWithStreamingResponse)WebsocketConnectionOptions)RealtimeClientEvent)RealtimeServerEvent)ConversationItemParam)RealtimeClientEventParam)ClientConnection)OpenAI AsyncOpenAIRealtime AsyncRealtimezlogging.Loggerlogc\rSrSr\S Sj5r\S Sj5r\S Sj5r\S Sj5r000S.SSjjr Sr g )r4@c,[UR5$N)r _clientselfs a/var/www/html/gaurav/venv/lib/python3.13/site-packages/openai/resources/beta/realtime/realtime.pysessionsRealtime.sessionsAs %%c,[UR5$r:)r&r;r<s r>transcription_sessionsRealtime.transcription_sessionsEs$T\\22rAc[U5$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 )RealtimeWithRawResponser<s r>with_raw_responseRealtime.with_raw_responseIs't,,rAc[U5$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 )RealtimeWithStreamingResponser<s r>with_streaming_response Realtime.with_streaming_responseSs-T22rA extra_query extra_headerswebsocket_connection_optionsc0[URUUUUS9$a The Realtime API enables you to build low-latency, multi-modal conversational experiences. It currently supports text and audio as both input and output, as well as function calling. Some notable benefits of the API include: - Native speech-to-speech: Skipping an intermediate text format means low latency and nuanced output. - Natural, steerable voices: The models have natural inflection and can laugh, whisper, and adhere to tone direction. - Simultaneous multimodal output: Text is useful for moderation; faster-than-realtime audio ensures stable playback. The Realtime API is a stateful, event-based API that communicates over a WebSocket. )clientrPrQrRmodel)RealtimeConnectionManagerr;r=rVrPrQrRs r>connectRealtime.connect\s$&)<<#')E   rAN)returnr )r\r&)r\rG)r\rL) rVstrrPrrQrrRr,r\rW __name__ __module__ __qualname____firstlineno__rr?rCrHrMrY__static_attributes__r[rAr>r4r4@s&&33--33 !#CE       'A   #  rAc\rSrSr\S Sj5r\S Sj5r\S Sj5r\S Sj5r000S.SSjjr Sr g )r5xc,[UR5$r:)r r;r<s r>r?AsyncRealtime.sessionsysT\\**rAc,[UR5$r:)r'r;r<s r>rC$AsyncRealtime.transcription_sessions}s)$,,77rAc[U5$rF)AsyncRealtimeWithRawResponser<s r>rHAsyncRealtime.with_raw_responses,D11rAc[U5$rK)"AsyncRealtimeWithStreamingResponser<s r>rM%AsyncRealtime.with_streaming_responses2$77rArOc0[URUUUUS9$rT)AsyncRealtimeConnectionManagerr;rXs r>rYAsyncRealtime.connects$&.<<#')E   rAr[N)r\r )r\r')r\rk)r\rn) rVr]rPrrQrrRr,r\rqr^r[rAr>r5r5xs++882288 !#CE       'A   (  rAcF\rSrSrSSjr\SSj5r\S Sj5rSrg) rGcXlgr: _realtimer=realtimes r>__init__ RealtimeWithRawResponse.__init__!rAc@[URR5$r:)rrwr?r<s r>r? RealtimeWithRawResponse.sessionss&t~~'>'>??rAc@[URR5$r:)r(rwrCr<s r>rC.RealtimeWithRawResponse.transcription_sessionss3DNN4Y4YZZrArvNryr4r\None)r\r)r\r( r_r`rarbrzrr?rCrcr[rAr>rGrGs3"@@[[rArGcF\rSrSrSSjr\SSj5r\S Sj5rSrg) rkcXlgr:rvrxs r>rz%AsyncRealtimeWithRawResponse.__init__r|rAc@[URR5$r:)rrwr?r<s r>r?%AsyncRealtimeWithRawResponse.sessionss+DNN,C,CDDrAc@[URR5$r:)r)rwrCr<s r>rC3AsyncRealtimeWithRawResponse.transcription_sessionss89^9^__rArvNryr5r\r)r\r)r\r)rr[rAr>rkrks3"EE``rArkcF\rSrSrSSjr\SSj5r\S Sj5rSrg) rLcXlgr:rvrxs r>rz&RealtimeWithStreamingResponse.__init__r|rAc@[URR5$r:)rrwr?r<s r>r?&RealtimeWithStreamingResponse.sessionss,T^^-D-DEErAc@[URR5$r:)r*rwrCr<s r>rC4RealtimeWithStreamingResponse.transcription_sessionss9$..:_:_``rArvNr)r\r)r\r*rr[rAr>rLrLs3"FFaarArLcF\rSrSrSSjr\SSj5r\S Sj5rSrg) rncXlgr:rvrxs r>rz+AsyncRealtimeWithStreamingResponse.__init__r|rAc@[URR5$r:)rrwr?r<s r>r?+AsyncRealtimeWithStreamingResponse.sessionss1$..2I2IJJrAc@[URR5$r:)r+rwrCr<s r>rC9AsyncRealtimeWithStreamingResponse.transcription_sessionss>t~~?d?deerArvNr)r\r)r\r+rr[rAr>rnrns3"KKffrArnc\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S \S'S\S'SSjrSSjrSSjrS Sjr S!Sjr SSS.S"Sjjr S#Sjr Sr g)$AsyncRealtimeConnection:Represents a live websocket connection to the Realtime APIAsyncRealtimeSessionResourcesessionAsyncRealtimeResponseResourceresponse%AsyncRealtimeInputAudioBufferResourceinput_audio_buffer!AsyncRealtimeConversationResource conversation&AsyncRealtimeOutputAudioBufferResourceoutput_audio_buffer)AsyncRealtimeTranscriptionSessionResourcetranscription_sessionAsyncWebsocketConnection _connectioncXl[U5Ul[U5Ul[ U5Ul[U5Ul[U5Ul [U5Ul gr:) rrrrrrrrrrrrrr= connections r>rz AsyncRealtimeConnection.__init__sT%3D9 5d; "G"M=dC#I$#O %Nt%T"rAcp# SSKJn UR5IShvN 7v MN !Ua gf=f7fzY An infinite-iterator that will continue to yield events until the connection is closed. r)ConnectionClosedOKNwebsockets.exceptionsrrecvr=rs r> __aiter__!AsyncRealtimeConnection.__aiter__s: =  IIK'''!   s 6*( *3636c\# URUR5IShvN 5$N7f) Receive the next message from the connection and parses it into a `RealtimeServerEvent` object. Canceling this method is safe. There's no risk of losing data. N parse_event recv_bytesr<s r>rAsyncRealtimeConnection.recvs% doo&7 788 7s ,* ,c# URRSS9IShvN n[RS[ U55 U$N%7f)Receive the next message from the connection as raw bytes. Canceling this method is safe. There's no risk of losing data. If you want to parse the message into a `RealtimeServerEvent` object like `.recv()` does, then you can call `.parse_event(data)`. FdecodeN$Received WebSocket message: %i bytesrrr6debuglenr=messages r>r"AsyncRealtimeConnection.recv_bytess@((--U-;; 8#g,GrAsyncRealtimeConnection.sendsk%++ MMtSWM X"7?W"XXY ##D)))Y)s$A A= A9 &A=3A;4A=;A=codereasoncR# URRXS9IShvN gN7fNrrcloser=rrs r>rAsyncRealtimeConnection.close#s"$$$$>>>s '%'c ~[[[[R"U5[[ [5S95$z Converts a raw `str` or `bytes` message into a `RealtimeServerEvent` object. This is helpful if you're using `.recv_bytes()`. )valuetype_rr.rrloadsrr=rs r>r#AsyncRealtimeConnection.parse_event&1  !9 4@PX\]`buXv!w  rArrrrrrrN)rrr\r)r\z"AsyncIterator[RealtimeServerEvent]r\r.r\bytesrz.RealtimeClientEvent | RealtimeClientEventParamr\rrintrr]r\rrz str | bytesr\r.)r_r`rarb__doc____annotations__rzrrrrrrrcr[rAr>rrsZD ))++==33??DD))U 9 **.R? rArcl\rSrSrSrS SjrS Sjr\rS SjrS Sjr Sr g) rqi1a Context manager over a `AsyncRealtimeConnection` that is returned by `beta.realtime.connect()` This context manager ensures that the connection will be closed when it exits. --- Note that if your application doesn't work well with the context manager approach then you can call the `.enter()` method directly to initiate a connection. **Warning**: You must remember to close the connection with `.close()`. ```py connection = await client.beta.realtime.connect(...).enter() # ... await connection.close() ``` cNXlX lSUlX0lX@lXPlgr:)'_AsyncRealtimeConnectionManager__client&_AsyncRealtimeConnectionManager__model+_AsyncRealtimeConnectionManager__connection,_AsyncRealtimeConnectionManager__extra_query._AsyncRealtimeConnectionManager__extra_headers=_AsyncRealtimeConnectionManager__websocket_connection_optionsr=rUrVrPrQrRs r>rz'AsyncRealtimeConnectionManager.__init__Es(  <@(,.J+rAc |# SSKJn URnUR R 5IShvN UR Rn[UR 5(a7SSK J n UR RURU5IShvN upTOMUR5R0UR RR ESUR0EUES9n["R%S5 UR&(a["R%S 5 [)U"[+U54UR R,[/0UES S 0EUR05S .UR&D6IShvN 5UlUR2$![an[S5UeSnAff=fGNGN N=7f) u? 👋 If your application doesn't work well with the context manager approach then you can call this method directly to initiate a connection. **Warning**: You must remember to close the connection with `.close()`. ```py connection = await client.beta.realtime.connect(...).enter() # ... await connection.close() ``` r)_WebSocketConnect9You need to install `openai[realtime]` to use this methodN)_AzureWebSocketConnectrVparamsConnecting to WebSocket API,Custom WebSocket connection options provided OpenAI-Beta realtime=v1user_agent_headeradditional_headers)lib._websocketr ImportErrorr!rr_refresh_api_key auth_headersrlib._azure_websocketr_configure_realtimer _prepare_url copy_withbase_urlrr6rrrr] user_agentr"rrr=rYexcrPrurls r> __aenter__)AsyncRealtimeConnectionManager.__aenter__Us d G(( mm,,...}}11  / / R&*mm&G&G Va&b b C##%//mm,,33T\\"0C /0  . . IID E3C "&--":":#2&%}(( $ 55       K dYZ`c c d / !c sWF<F)F<F4A#F<F7C$F<<F:=F< F1 F,,F11F<7F<:F<cURRb [URR5nO#URRR SS9nUR R S5S-nUR US9$Nwss)scheme/s /realtime)raw_path)rwebsocket_base_urlr _base_urlrr$rstripr=rmerge_raw_paths r>r+AsyncRealtimeConnectionManager._prepare_urlr == + + 7*4==+K+KLH}}..888FH!**11$7,F!!>!::rAcp# URb#URR5IShvN ggN7fr:)rrr=exc_typerexc_tbs r> __aexit__(AsyncRealtimeConnectionManager.__aexit__s3    (##))+ + + ) +s +646__client __connection__extra_headers __extra_query__model__websocket_connection_optionsN) rUr3rVr]rPrrQrrRr,r\r)r\rr\z httpx2.URLr.ztype[BaseException] | NonerzBaseException | Noner/zTracebackType | Noner\r) r_r`rarbrrzrenterrr0rcr[rAr>rqrq1s&KK K  K  K'AK K 4!l E;,2,9M,Wk, ,rArqc\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S \S'S\S'SSjrSSjrSSjrS Sjr S!Sjr SSS.S"Sjjr S#Sjr Sr g)$RealtimeConnectionirRealtimeSessionResourcerRealtimeResponseResourcer RealtimeInputAudioBufferResourcerRealtimeConversationResourcer!RealtimeOutputAudioBufferResourcer$RealtimeTranscriptionSessionResourcerWebsocketConnectionrcXl[U5Ul[U5Ul[ U5Ul[U5Ul[U5Ul [U5Ul gr:) rr>rr?rr@rrArrBrrCrrs r>rzRealtimeConnection.__init__sT%.t4 06 "B4"H8>#DT#J %I$%O"rAc#Z# SSKJn UR5v M!Ua gf=f7frrrs r>__iter__RealtimeConnection.__iter__s4 = iik!!   s+(+(+c@URUR55$)rrr<s r>rRealtimeConnection.recvs  122rAcvURRSS9n[RS[ U55 U$)rFrrrrs r>rRealtimeConnection.recv_bytess5""''u'5 8#g,GrAc[U[5(aURSSSS9O#[R"[ U[ 55nURRU5 gr) rr rrrrr0rrrs r>rRealtimeConnection.sendsU%++ MMtSWM XOE3KLM d#rArrrc6URRXS9 grrrs r>rRealtimeConnection.closes D8rAc ~[[[[R"U5[[ [5S95$rrrs r>rRealtimeConnection.parse_eventrrArN)rrDr\r)r\zIterator[RealtimeServerEvent]rrrrr)r_r`rarbrrrzrHrrrrrrcr[rAr>r=r=sZD $$&&88..::??$$P 3 $$(r9 rAr=cl\rSrSrSrS SjrS Sjr\rS SjrS Sjr Sr g) rWia Context manager over a `RealtimeConnection` that is returned by `beta.realtime.connect()` This context manager ensures that the connection will be closed when it exits. --- Note that if your application doesn't work well with the context manager approach then you can call the `.enter()` method directly to initiate a connection. **Warning**: You must remember to close the connection with `.close()`. ```py connection = client.beta.realtime.connect(...).enter() # ... connection.close() ``` cNXlX lSUlX0lX@lXPlgr:)"_RealtimeConnectionManager__client!_RealtimeConnectionManager__model&_RealtimeConnectionManager__connection'_RealtimeConnectionManager__extra_query)_RealtimeConnectionManager__extra_headers8_RealtimeConnectionManager__websocket_connection_optionsrs r>rz"RealtimeConnectionManager.__init__s(  7;(,.J+rAc (SSKJn URnUR R 5 UR Rn[UR 5(a)UR RURU5upTOMUR5R0UR RRESUR0EUES9n[R!S5 UR"(a[R!S5 [%U"['U54UR R([+0UES S 0EUR,5S .UR"D65UlUR.$![an[S5UeSnAff=f) u3 👋 If your application doesn't work well with the context manager approach then you can call this method directly to initiate a connection. **Warning**: You must remember to close the connection with `.close()`. ```py connection = client.beta.realtime.connect(...).enter() # ... connection.close() ``` r)rYrNrVrr r r r r )websockets.sync.clientrYrr!rYrVrrrrrWrrrrr6rr[r=r]rr"rZrXrs r> __enter__#RealtimeConnectionManager.__enter__sx d 6((  &&(}}11 4== ) ) $ A A$,,P[ \ C##%//mm,,33T\\"0C /0  . . IID E. C "&--":":#2&%}(( $ 55      G dYZ`c c dsE66 F F  FcURRb [URR5nO#URRR SS9nUR R S5S-nUR US9$r )rVr%rr&rr$r'r(s r>r&RealtimeConnectionManager._prepare_urlDr+rAcTURbURR5 ggr:)rXrr-s r>__exit__"RealtimeConnectionManager.__exit__Ms'    (    # # % )rAr2N) rUr2rVr]rPrrQrrRr,r\r)r\r=r9r:) r_r`rarbrrzr_r;rrdrcr[rAr>rWrWs&KK K  K  K'AK K 2!h E;&2&9M&Wk& &rArWc\rSrSrSSjrSrg)BaseRealtimeConnectionResourceiTcXlgr:rrs r>rz'BaseRealtimeConnectionResource.__init__U%rAriN)rr=r\rr_r`rarbrzrcr[rAr>rgrgT&rArgc&\rSrSr\S.SSjjrSrg)r>iYevent_idc nURR[[[ SXS.555 gu Send this event to update the session’s default configuration. The client may send this event at any time to update any field, except for `voice`. However, note that once a session has been initialized with a particular `model`, it can’t be changed to another model using `session.update`. When the server receives a `session.update`, it will respond with a `session.updated` event showing the full, effective configuration. Only the fields that are present are updated. To clear a field like `instructions`, pass an empty string. zsession.updatetyperrpNrrrr0rr=rrps r>updateRealtimeSessionResource.updateZs1  ()9g de  rAr[Nrz"session_update_event_param.Sessionrpstr | NotGivenr\rr_r`rarbrrwrcr[rAr>r>r>Ys`i  rAr>cF\rSrSr\\S.SSjjr\\S.S SjjrSrg) r?iorprc nURR[[[ SXS.555 ga This event instructs the server to create a Response, which means triggering model inference. When in Server VAD mode, the server will create Responses automatically. A Response will include at least one Item, and may have two, in which case the second will be a function call. These Items will be appended to the conversation history. The server will respond with a `response.created` event, events for Items and content created, and finally a `response.done` event to indicate the Response is complete. The `response.create` event includes inference configuration like `instructions`, and `temperature`. These fields will override the Session's configuration for this Response only. zresponse.create)rtrprNrur=rprs r>createRealtimeResponseResource.createps1.  (): gh  rArp response_idc nURR[[[ SXS.555 gzSend this event to cancel an in-progress response. The server will respond with a `response.done` event with a status of `response.status=cancelled`. If there is no response to cancel, the server will respond with an error. zresponse.cancel)rtrprNrur=rprs r>cancelRealtimeResponseResource.cancels1  (): mn  rAr[Nrprzrz/response_create_event_param.Response | NotGivenr\rrprzrrzr\rr_r`rarbrrrrcr[rAr>r?r?os@$-DM  ! B    <4=\e   rAr?cJ\rSrSr\S.SSjjr\S.SSjjr\S.S SjjrSrg) r@iroc nURR[[[ SUS.555 gz}Send this event to clear the audio bytes in the buffer. The server will respond with an `input_audio_buffer.cleared` event. zinput_audio_buffer.clearrtrpNrur=rps r>clear&RealtimeInputAudioBufferResource.clears/  )?D^lt;u+v w rAc nURR[[[ SUS.555 ga" Send this event to commit the user input audio buffer, which will create a new user message item in the conversation. This event will produce an error if the input audio buffer is empty. When in Server VAD mode, the client does not need to send this event, the server will commit the audio buffer automatically. Committing the input audio buffer will trigger input audio transcription (if enabled in session configuration), but it will not create a response from the model. The server will respond with an `input_audio_buffer.committed` event. zinput_audio_buffer.commitrNrurs r>commit'RealtimeInputAudioBufferResource.commits/  )?D_mu;v+w x rAc nURR[[[ SXS.555 gaSSend this event to append audio bytes to the input audio buffer. The audio buffer is temporary storage you can write to and later commit. In Server VAD mode, the audio buffer is used to detect speech and the server will decide when to commit. When Server VAD is disabled, you must commit the audio buffer manually. The client may choose how much audio to place in each event up to a maximum of 15 MiB, for example streaming smaller chunks from the client may allow the VAD to be more responsive. Unlike made other client events, the server will not send a confirmation response to this event. zinput_audio_buffer.append)rtaudiorpNrur=rrps r>append'RealtimeInputAudioBufferResource.appends1  ()Du kl  rAr[Nrprzr\rrr]rprzr\r r_r`rarbrrrrrcr[rAr>r@r@s%2; 4= "@I  rAr@c(\rSrSr\SSj5rSrg)rAic,[UR5$r:) RealtimeConversationItemResourcerr<s r>item!RealtimeConversationResource.items/0@0@AArAr[N)r\rr_r`rarbrrrcr[rAr>rArAsBBrArAc~\rSrSr\S.S Sjjr\\S.S Sjjr\S.S Sjjr\S.S SjjrSr g ) riroc nURR[[[ SXS.555 gaSend this event when you want to remove any item from the conversation history. The server will respond with a `conversation.item.deleted` event, unless the item does not exist in the conversation history, in which case the server will respond with an error. zconversation.item.deletertitem_idrpNrur=rrps r>delete'RealtimeConversationItemResource.deletes2  ()CPW no  rArpprevious_item_idc rURR[[[ SUUUS.555 ga Add a new Item to the Conversation's context, including messages, function calls, and function call responses. This event can be used both to populate a "history" of the conversation and to add new items mid-stream, but has the current limitation that it cannot populate assistant audio messages. If successful, the server will respond with a `conversation.item.created` event, otherwise an `error` event will be sent. zconversation.item.create)rtrrprNrur=rrprs r>r'RealtimeConversationItemResource.creates<  ( : $$,,<   rAc tURR[[[ SUUUUS.555 gu4Send this event to truncate a previous assistant message’s audio. The server will produce audio faster than realtime, so this event is useful when the user interrupts to truncate audio that has already been sent to the client but not yet played. This will synchronize the server's understanding of the audio with the client's playback. Truncating audio will delete the server-side text transcript to ensure there is not text in the context that hasn't been heard by the user. If successful, the server will respond with a `conversation.item.truncated` event. zconversation.item.truncate)rt audio_end_ms content_indexrrpNrur=rrrrps r>truncate)RealtimeConversationItemResource.truncates?"  ( <(4)6#*$,   rAc nURR[[[ SXS.555 ga Send this event when you want to retrieve the server's representation of a specific item in the conversation history. This is useful, for example, to inspect user audio after noise cancellation and VAD. The server will respond with a `conversation.item.retrieved` event, unless the item does not exist in the conversation history, in which case the server will respond with an error. zconversation.item.retrieverNrurs r>retrieve)RealtimeConversationItemResource.retrieve#s2  ()ERY pq  rAr[Nrr]rprzr\rrr/rprzrrzr\r rrrrrr]rprzr\r r_r`rarbrrrrrrcr[rAr>rrsAJ  &$-+4  $ !  )    >bk " 36 AD P^  @DM   rArc&\rSrSr\S.SSjjrSrg)rBi2roc nURR[[[ SUS.555 ga**WebRTC Only:** Emit to cut off the current audio response. This will trigger the server to stop generating audio and emit a `output_audio_buffer.cleared` event. This event should be preceded by a `response.cancel` client event to stop the generation of the current response. [Learn more](https://platform.openai.com/docs/guides/realtime-conversations#client-and-server-events-for-audio-in-webrtc). zoutput_audio_buffer.clearrNrurs r>r'RealtimeOutputAudioBufferResource.clear3s/  )?D_mu;v+w x rAr[Nrr_r`rarbrrrcr[rAr>rBrB2s2;   rArBc0\rSrSr\S.SSjjrSrg)rCiAroc nURR[[[ SXS.555 gz2Send this event to update a transcription session.ztranscription_session.updatersNrurvs r>rw+RealtimeTranscriptionSessionResource.updateBs2  ()GT[ rs  rAr[Nrz*transcription_session_update_param.Sessionrprzr\rr{r[rAr>rCrCA'aj  D  P^     rArCc\rSrSrSSjrSrg)#BaseAsyncRealtimeConnectionResourceiNcXlgr:rirs r>rz,BaseAsyncRealtimeConnectionResource.__init__OrkrAriN)rrr\rrlr[rAr>rrNrmrArc0\rSrSr\S.SSjjrSrg)riSroc # URR[[[ SXS.555IShvN gN7frrrurvs r>rw#AsyncRealtimeSessionResource.updateTs>## ()9g de    9AAAr[Nryr{r[rAr>rrSs'Yb < HV   rArcF\rSrSr\\S.SSjjr\\S.S SjjrSrg) rikr}c # URR[[[ SXS.555IShvN gN7frrurs r>r$AsyncRealtimeResponseResource.createls>.## (): gh    rrc # URR[[[ SXS.555IShvN gN7frrurs r>r$AsyncRealtimeResponseResource.cancels>## (): mn    rr[Nrrrr[rAr>rrksA$-DM  ! B    <:Cbk   rArcJ\rSrSr\S.SSjjr\S.SSjjr\S.S SjjrSrg) riroc # URR[[[ SUS.555IShvN gN7frrurs r>r+AsyncRealtimeInputAudioBufferResource.clears< ## )?D^lt;u+v w   rc # URR[[[ SUS.555IShvN gN7frrurs r>r,AsyncRealtimeInputAudioBufferResource.commits<## )?D_mu;v+w x   rc # URR[[[ SXS.555IShvN gN7frrurs r>r,AsyncRealtimeInputAudioBufferResource.appends>## ()Du kl    rr[Nrrrr[rAr>rrs&8A :C "FO  rArc(\rSrSr\SSj5rSrg)ric,[UR5$r:)%AsyncRealtimeConversationItemResourcerr<s r>r&AsyncRealtimeConversationResource.items4T5E5EFFrAr[N)r\rrr[rAr>rrsGGrArc~\rSrSr\S.S Sjjr\\S.S Sjjr\S.S Sjjr\S.S SjjrSr g ) riroc # URR[[[ SXS.555IShvN gN7frrurs r>r,AsyncRealtimeConversationItemResource.deletes?## ()CPW no    rrc # URR[[[ SUUUS.555IShvN gN7frrurs r>r,AsyncRealtimeConversationItemResource.createsI ## ( : $$,,<    s;AAAc # URR[[[ SUUUUS.555IShvN gN7frrurs r>r.AsyncRealtimeConversationItemResource.truncatesL"## ( <(4)6#*$,    sr.AsyncRealtimeConversationItemResource.retrieves?## ()ERY pq    rr[Nrrrrr[rAr>rrsGP  &$-+4  $ !  )    >bk " 36 AD P^  @JS   rArc&\rSrSr\S.SSjjrSrg)ri.roc # URR[[[ SUS.555IShvN gN7frrurs r>r,AsyncRealtimeOutputAudioBufferResource.clear/s<## )?D_mu;v+w x   rr[Nrrr[rAr>rr.s8A   rArc0\rSrSr\S.SSjjrSrg)ri=roc # URR[[[ SXS.555IShvN gN7frrurvs r>rw0AsyncRealtimeTranscriptionSessionResource.update>s?## ()GT[ rs    rr[Nrr{r[rAr>rr=rrAr)k __future__rrloggingtypesrtypingrrrrtyping_extensionsr httpx2pydanticr r?r r rrrr_typesrrrr_utilsrrrrr_compatr_httpx2r_modelsr _resourcerr _exceptionsr! _base_clientr"types.beta.realtimer#r$r%rCr&r'r(r)r*r+"types.websocket_connection_optionsr,)types.beta.realtime.realtime_client_eventr-)types.beta.realtime.realtime_server_eventr.+types.beta.realtime.conversation_item_paramr//types.beta.realtime.realtime_client_event_paramr0r^r1rDwebsockets.asyncio.clientrr;r2r3__all__ getLoggerr_r6rr4r5rGrkrLrnrrqr=rWrgr>r?r@rArrBrCrrrrrrrrr[rAr>rs" 55+ ;:(+0;', NMMQXNV/  '''1^15 5 p5 $5 p [ [ ` ` a a f fJ J Zi,i,XJ J Zg&g&T&&  < ,+ =+ \/ 'E/ dB#AB Z 'EZ z  (F    +I  &&  #F 0+ $G+ \/ ,O/ dG(KG Z ,OZ z  -P    0S  rA