uPjrUdZddlZddlZddlZddlmZmZddlm Z ddl m Z ddl mZddl mZddlmZdd lmZdd lmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!dd l"m#Z#m$Z$m%Z%dd l&m'Z'Gd de Z(dZ)ee*d<e)dzZ+ee*d<e,e+dzZ-ee*d<e,e+dzZ.ee*d<dZ/ee*d<GddeZ0y)z This file contains the transformation logic for Bedrock Nova Sonic realtime API. Transforms between OpenAI Realtime API format and Bedrock Nova Sonic format. N)AnyFinal) BaseModel)verbose_logger)uuid)Logging)BaseRealtimeConfig)ready_trigger_pcm) OpenAIRealtimeContentPartDoneOpenAIRealtimeDoneEventOpenAIRealtimeEventsOpenAIRealtimeOutputItemDoneOpenAIRealtimeResponseAudioDone&OpenAIRealtimeResponseContentPartAddedOpenAIRealtimeResponseDelta OpenAIRealtimeResponseDoneObjectOpenAIRealtimeResponseTextDone&OpenAIRealtimeStreamResponseBaseObject+OpenAIRealtimeStreamResponseOutputItemAddedOpenAIRealtimeStreamSession!OpenAIRealtimeStreamSessionEvents)ALL_DELTA_TYPESRealtimeResponseTransformInputRealtimeResponseTypedDict)get_empty_usagec"eZdZUdZedzed<y)BedrockContentEndN stopReason)__name__ __module__ __qualname__rstr__annotations__q/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/llms/bedrock/realtime/transformation.pyrr*s!Jd !r%r>TRIGGER_AUDIO_SAMPLE_RATE_HERTZTRIGGER_AUDIO_BYTES_PER_SECONDTRIGGER_LEADING_SILENCETRIGGER_TRAILING_SILENCETRIGGER_AUDIO_CHUNK_SIZEceZdZdZdZd3dedededzdefdZd3d edzdededzdefd Zde fd Z d3ded e edzdefd Z d e ede efdZ d4dede defdZdede efdZdede efdZdede efdZdede efdZdede efdZde efdZdede efdZde efdZ d3dedededzde efdZ d3dedede edzdefd Zdededefd!Z d3dedede edzdefd"Zd#ed$edzd%edzd&edzdee e edzedzedze!dzff d'Z"d#ed%edzd$edzd(e e#dzdee e e e#dzff d)Z$d#ed%edzd$edzde e fd*Z%d#ed%edzd$edzd+edzd(e e#dzdee e e e#dzff d,Z&d#ed$edzd&edzdee e edzedze!dzffd-Z'd$edzd&edzdee e edzedze!dzffd.Z(d#ed%edzd$edzdee e eeffd/Z)dede efd0Z*dee+zdeded1e,de-f d2Z.y)5BedrockRealtimeConfigz>Configuration for Bedrock Nova Sonic realtime transformations.cttj|_ttj|_ttj|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d |_d |_d |_d |_d|_d|_d |_d |_d |_d |_y)NFr.g?gffffff?]matthewbase64SPEECHz audio/lpcmr' text/plain)r"uuid_libuuid4 prompt_name content_nameaudio_content_nameprompt_startedclient_audio_streamed max_tokenstop_p temperatureoutput_sample_rate_hertzoutput_sample_size_bitsoutput_channel_countvoice_idoutput_encodingoutput_audio_typeoutput_media_typeinput_sample_rate_hertzinput_sample_size_bitsinput_channel_countinput_encodinginput_audio_typeinput_media_typetext_media_typeselfs r&__init__zBedrockRealtimeConfig.__init__8sx~~/0 01"%hnn&6"7#%*" ).%')$$%!! '!)!-(-$&(##$ & ( , ,r%Nheadersmodelapi_keyreturnc|S)z@Validate environment - no special validation needed for Bedrock.r$)rSrUrVrWs r&validate_environmentz*BedrockRealtimeConfig.validate_environmentZsr%api_basec|xsdS)z6Get complete URL - handled by aws_sdk_bedrock_runtime.r$)rSr[rVrWs r&get_complete_urlz&BedrockRealtimeConfig.get_complete_url^s ~2r%cy)z'Bedrock requires session configuration.Tr$rRs r&requires_session_configurationz4BedrockRealtimeConfig.requires_session_configurationbsr%toolsc ddd|j|j|jdiii}|jd|ji|j |j |j|j|j|j|jdd}|rddi|d <d |j|i|d <dd |ii}tj||d S)z Create initial session configuration for Bedrock Nova Sonic. Args: model: Model ID tools: Optional list of tool definitions Returns JSON string with session start and prompt start events. event sessionStartinferenceConfiguration maxTokenstopPrC mediaTyperisampleRateHertzsampleSizeBits channelCountvoiceIdencoding audioType promptNametextOutputConfigurationaudioOutputConfigurationapplication/jsontoolUseOutputConfigurationratoolConfiguration promptStart) session_start prompt_start)rArBrCr<rQrJrDrErFrGrHrI"_transform_tools_to_bedrock_formatjsondumps)rSrVraryprompt_start_configrzs r&session_configuration_requestz3BedrockRealtimeConfig.session_configuration_requestfs ,%)__ $ '+'7'7/! **(3T5I5I'J!33#'#@#@"&">"> $ 9 9== 00!33) &  ALN`@a  < =8?AhAhinAo7p  3 4&8K(LM zzM<XYYr%c "g}|D]}|jddk(s|jdi}d|jdd|jdddtj|jdiid i}|j||S) z Transform OpenAI tool format to Bedrock tool format. Args: tools: List of OpenAI format tools Returns: List of Bedrock format tools typefunctiontoolSpecnamer] descriptionr| parameters)rr inputSchema)getr|r}append)rSra bedrock_toolstoolr bedrock_tools r&r{z8BedrockRealtimeConfig._transform_tools_to_bedrock_formats "  3Dxx:-88J3 ( VR 8'/||M2'F(. 8<< VX;Y0Z'[!  $$\2 3r% audio_format is_outputc.|dk(r|rdSdS|dvry|rdSdS)a Map OpenAI audio format to sample rate. Args: audio_format: OpenAI audio format (pcm16, g711_ulaw, g711_alaw) is_output: Whether this is for output (True) or input (False) Returns: Sample rate in Hz pcm16r3r') g711_ulaw g711_alawi@r$)rSrrs r& _map_audio_format_to_sample_ratez6BedrockRealtimeConfig._map_audio_format_to_sample_rates2 7 "%5 05 0 7 7!u,u,r% json_messagec ftjdg}|jdi}d|vr |d|_d|vr |d|_d|vr |d|_d|vr|d}|j |d|_d |vr|d }|j |d |_d |vr |d |_d |vr |d |_d dd|j|j|jdiii}|jtj||jd|ji|j|j|j |j"|j |j$|j&dd}|jd}|rddi|d<d|j)|i|d<d d|ii} |jtj| d|_|jd} | rt-t/j0} d d|j| dd dd|jidii} |jtj| d d|j| | dii} |jtj| d d |j| d!ii}|jtj||S)"z Transform session.update event to Bedrock session configuration. Args: json_message: OpenAI session.update message Returns: List of Bedrock format messages (JSON strings) zHandling session.updatesessionmax_response_output_tokensrCvoiceoutput_audio_formatT)rinput_audio_formatFrDrKrcrdrerfrirjrqrarurvrwrx instructions contentStartTEXTSYSTEMrr contentNamer interactiveroletextInputConfiguration textInputrrrcontent contentEndrrr)rdebugrrArCrGrrDrKrBrr|r}r<rQrJrErFrHrIr{r?r"r:r;)rSrmessagessession_config output_format input_formatryr~rarzrtext_content_nametext_content_start text_inputtext_content_ends r&transform_session_update_eventz4BedrockRealtimeConfig.transform_session_update_events 67%' , 0 0B ? (> 9,-IJDO N *-m 1"01E"FL+/+P+PQ]in+P+oD ( & 7,:;U,VD ) $ 6+9:S+TD ( ,%)__ $ '+'7'7/!   =12**(3T5I5I'J!33#'#@#@"&">"> $ 9 9== 00!33) & &))'2 ALN`@a  < =8?AhAhinAo7p  3 4&8K(LM  <01"-00@ '*8>>+;'< "&*&6&6'8 &', (3>@T@T2U %  )  OODJJ'9: ;&*&6&6'8#/"!J OODJJz2 3 &*&6&6'8#'  OODJJ'78 9r%cjtjdd|_g}t|dr|j|j k7rodd|j |jdii}|jtj|t|dttj|_t|dsdd|j |jddd |j|j |j |j"|j$|j&d d ii}|jtj|d|_|j |_|j+d d }dd|j |j|dii}|jtj||S)z Transform input_audio_buffer.append event to Bedrock audio input. Args: json_message: OpenAI input_audio_buffer.append message Returns: List of Bedrock format messages (JSON strings) z"Handling input_audio_buffer.appendT_audio_content_startedrcrrrAUDIOUSERrirkrlrmrprorrrrrraudioInputConfigurationaudior] audioInputr)rrr@hasattr_audio_content_sample_raterKr<r>rr|r}delattrr"r:r;rPrLrMrOrNrr)rSrrmismatched_content_endaudio_content_start audio_data audio_events r&)transform_input_audio_buffer_append_eventz?BedrockRealtimeConfig.transform_input_audio_buffer_append_event:s AB%)"%' 41 2t7V7VZ^ZvZv7v &*&6&6'+'>'>#- " OODJJ'=> ? D2 3&)(..*:&;D #t56"&*&6&6'+'>'> ''+ &)-)>)>/3/K/K.2.I.I,0,D,D)-)>)>(,(;(; 4 %* & OODJJ':; <*.D '.2.J.JD +),,Wb9 "&"2"2#'#:#:)   ;/0r%ctjdg}t|drMdd|j|jdii}|j t j|t|d|S)z Transform input_audio_buffer.commit event to Bedrock audio content end. Args: json_message: OpenAI input_audio_buffer.commit message Returns: List of Bedrock format messages (JSON strings) z"Handling input_audio_buffer.commitrrcrr) rrrr<r>rr|r}r)rSrraudio_content_ends r&)transform_input_audio_buffer_commit_eventz?BedrockRealtimeConfig.transform_input_audio_buffer_commit_event}su AB%' 41 2 &*&6&6'+'>'>#(  OODJJ'89 : D2 3r%c tjd|jdi}|jd}|dk(r|j|Sg}|dk(r|jdg}|D]}|jddk(st t j }dd |j|d d d d |jidii}|jtj|dd|j||jdddii} |jtj| dd|j|dii} |jtj| |S)z Transform conversation.item.create event to Bedrock text input or tool result. Args: json_message: OpenAI conversation.item.create message Returns: List of Bedrock format messages (JSON strings) z!Handling conversation.item.createitemrfunction_call_outputmessager input_textrcrrTrrirrtextr]rrr) rrr4transform_conversation_item_create_tool_result_eventr"r:r;r<rQrr|r}) rSrr item_typerr content_partrrrrs r&(transform_conversation_item_create_eventz>BedrockRealtimeConfig.transform_conversation_item_create_events @A"&&vr288F+  . .LL\Z Z%'  !!XXi4G '( B ##F+|;(+HNN,<(=% *.2.>.>/@(./3(.;FH\H\:] - " *&OODJJ/A$BC '.2.>.>/@+7+;+;FB+G*""JOODJJz$:; (.2.>.>/@+"($OODJJ/?$@AQ( BTr%ctjd|jr |jrgSg}t |dsdd|j |j ddd|jt|j|j|j|jdd ii}|jtj|d|_t|_|j%|j'|S) aa Transform response.create event to Bedrock format. Nova Sonic only starts generating after it detects user speech, so text-only sessions never get a response on their own. Injecting a short spoken "ready" utterance (followed by silence) makes the model respond to the pending interactive text input. Sessions where the client streams its own audio rely on Nova Sonic's built-in turn detection instead. Args: json_message: OpenAI response.create message Returns: List of Bedrock format messages (JSON strings) zHandling response.createrrcrrTrrr)rrr?r@rr<r>rPr(rLrMrOrNrr|r}rrextend _response_trigger_audio_messages)rSrrtrigger_content_starts r&transform_response_create_eventz5BedrockRealtimeConfig.transform_response_create_events 78""d&@&@I%'t56"&*&6&6'+'>'> ''+ &)-)>)>/N.2.I.I,0,D,D)-)>)>(,(;(; 4 %, !& OODJJ'<= >*.D '.MD +==?@r%c@ttztz}tdt |t Dcgc]^}t jdd|j|jtj|||t zjdii`c}Scc}w)Nrrcrr) r+r r-rangelenr/r|r}r<r>r7 b64encodedecode)rSpcmoffsets r&rz6BedrockRealtimeConfig._response_trigger_audio_messages s,/@/BBE]] 3s8-EF   JJ$*.*:*:+/+B+B'-'7'7FVNfEf8g'h'o'o'q'    sA#Bc0tjdgS)z Transform response.cancel event to Bedrock format. Args: json_message: OpenAI response.cancel message Returns: List of Bedrock format messages (JSON strings) zHandling response.cancel)rr)rSrs r&transform_response_cancel_eventz5BedrockRealtimeConfig.transform_response_cancel_events 78 r%c|jsgSg}t|drMdd|j|jdii}|j t j |t|d|j t j ddd|jiii|j t j ddiiid|_|S) z Build the Bedrock events that gracefully close the session (contentEnd for any open audio content, promptEnd, sessionEnd). Returns: List of Bedrock format messages (JSON strings) rrcrr promptEndrr sessionEndF)r?rr<r>rr|r}r)rSrrs r&session_close_messagesz,BedrockRealtimeConfig.session_close_messages+s""I%' 41 2 &*&6&6'+'>'>#(  OODJJ'89 : D2 3 GkL$JZJZ;[-\#]^_ GlB-?#@AB#r%rrc tj|}|j d}|dk(r|j |S|dk(r|j|S|dk(r|j|S|dk(r|j|S|d k(r|j|S|d k(r|j|Stjd |gS#tj$rtjd|ddgcYSwxYw) aE Transform OpenAI realtime request to Bedrock Nova Sonic format. Args: message: OpenAI format message (JSON string) model: Model ID session_configuration_request: Previous session config Returns: List of Bedrock format messages (JSON strings) Invalid JSON message: %sNrzsession.updatezinput_audio_buffer.appendzinput_audio_buffer.commitzconversation.item.createzresponse.createzresponse.cancelzUnknown message type: %s) r|loadsJSONDecodeErrorrwarningrrrrrrr)rSrrVrr message_types r&transform_realtime_requestz0BedrockRealtimeConfig.transform_realtime_requestHs" "&**W"5L +..v6  + +66|D D 8 8AA,O O 8 8AA,O O 7 7@@N N . .77 E E . .77 E E  " "#=| LI+##   " "#=wt} MI sC.C54C5 logging_obj modalitiescnt|j||nddg}|t|tr||d<|S)Nrr)idrrV)rlitellm_trace_id isinstancer")rSrVrrrs r&_session_objectz%BedrockRealtimeConfig._session_objectrsF 5++%/%;z&'AR   E3!7$GG r%cttd|j||ttjS)zABuild the OpenAI session.created event for this realtime session.zsession.createdrrevent_idrrr"rr;)rSrVrs r&session_created_eventz+BedrockRealtimeConfig.session_created_events2 1"(( <&  r%cvtd|j|||ttjS)zRBuild the OpenAI session.updated ack reflecting the client's requested modalities.zsession.updatedrr)rSrVrrs r&session_updated_eventz+BedrockRealtimeConfig.session_updated_events41"(( ZH&  r%rccurrent_response_idcurrent_output_item_idcurrent_conversation_idc |d}|jd}|dk7rg|||dfStjd|sdtj}|sdtj}|sdtj}|jd d }|d k(rd nd }g} t d dtjd|dg|d} | j | td|d|ddddgd} | j | tddddtj||d k(rd ddnd dd|} | j | | ||||fS)a Transform Bedrock contentStart event to OpenAI response events. Args: event: Bedrock contentStart event current_response_id: Current response ID current_output_item_id: Current output item ID current_conversation_id: Current conversation ID Returns: Tuple of (events, response_id, output_item_id, conversation_id, delta_type) rr ASSISTANTNzHandling ASSISTANT contentStartresp_item_conv_rrrrzresponse.createdevent_realtime.response in_progress)objectrstatusoutputconversation_idrrresponsezresponse.output_item.addedr realtime.itemr assistantrrrrrr)r response_id output_indexrzresponse.content_part.addedr]rrr transcript)r content_indexrritem_idpartr ) rrrrr;rrrr) rSrcrrr content_startr content_typecurrent_delta_typereturned_messagesresponse_createdoutput_item_addedcontent_part_addeds r&transform_content_start_eventz3BedrockRealtimeConfig.transform_content_start_events2 %^4 #''/ ; #&'   >?#$)$**,"8 %',TZZ\N%; "&(-djjl^&< #,//? ?Kv?UV[b?A#I#djjl^,-)'#:  #    !12$O-+,)!'#  $    !23%K.djjl^,*0Bf0L,[brtRu+ %    !34   " #    r%current_delta_chunksc tjd|djdd}|r|sg|fStdddt j |d||}|g}|j ||g|fS) a{ Transform Bedrock textOutput event to OpenAI response.text.delta. Args: event: Bedrock textOutput event current_output_item_id: Current output item ID current_response_id: Current response ID current_delta_chunks: Current delta chunks Returns: Tuple of (events, updated_delta_chunks) zHandling textOutput textOutputrr]zresponse.text.deltarrrrrrrr delta)rrrrrr;r)rSrcrrr text_content text_deltas r&transform_text_output_eventz1BedrockRealtimeConfig.transform_text_output_events& 23#L155iD %-@++ +7&djjl^,*+  '#% ##J/|111r%c tjd|djdd}|r|sgStdddt j |d||}|gS) a5 Transform Bedrock audioOutput event to OpenAI response.audio.delta. Args: event: Bedrock audioOutput event current_output_item_id: Current output item ID current_response_id: Current response ID Returns: List of OpenAI events zHandling audioOutput audioOutputrr]zresponse.audio.deltarrr )rrrrrr;)rSrcrr audio_content audio_deltas r&transform_audio_output_eventz2BedrockRealtimeConfig.transform_audio_output_event,sk" 34$]377 2F %-@I8'djjl^,*+ }r%rc |d}tjd||r|sg|fSg}|dk(rd}|r/dj|D cgc]} | jddc} }t dddt j |d|| } |j| td ddt j |dd|d | } |j| nw|d k(rrtdddt j |d|} |j| td ddt j |dd dd| } |j| tddt j d||ddddgd} |j| |dfScc} w)a Transform Bedrock contentEnd event to OpenAI response done events. Args: event: Bedrock contentEnd event current_output_item_id: Current output item ID current_response_id: Current response ID current_delta_type: Current delta type (text or audio) current_delta_chunks: Current delta chunks Returns: Tuple of (events, reset_delta_chunks) rzHandling contentEnd: %srr]r!zresponse.text.donerr)rrrrrr rzresponse.content_part.doner)rrrrrrr rzresponse.audio.done)rrrrrr rzresponse.output_item.doner r completedr r )rrrr rN) rrjoinrrrr;rr rr)rSrcrrrr content_endraccumulated_textchunk text_donecontent_part_done audio_doneoutput_item_dones r&transform_content_end_eventz1BedrockRealtimeConfig.transform_content_end_eventOs*#<0 6 D%-@++ +?A  '! ##%77Pd+euEIIgr,B+e#f =)!$**,0./% I  $ $Y /!>1!$**,0.$.>?/!   $ $%6 7 7 * ?*!$**,0./ !J  $ $Z 0!>1!$**,0.%R8/!   $ $%6 7#?,djjl^,+,)!%#  #    !12!$&&E,fsF cPtjd|j||S)a Transform a Bedrock end-of-response event (promptEnd, completionEnd, or an END_TURN contentEnd) to OpenAI response.done. Args: event: Bedrock event that ends the response current_response_id: Current response ID current_conversation_id: Current conversation ID Returns: Tuple of (events, reset_output_item_id, reset_response_id, reset_delta_type) zHandling promptEnd)rr_response_done_events)rSrcrrs r&transform_prompt_end_eventz0BedrockRealtimeConfig.transform_prompt_end_events(. 12))*=?VWWr%c|r|sgdddfSt}tddtjt d|dg||j |j |jd}|gdddfS)Nz response.donerrr+) prompt_tokenscompletion_tokens total_tokens)rrrrrusager)rr rr;rr9r:r;)rSrr usage_obj response_dones r&r6z+BedrockRealtimeConfig._response_done_eventss#*AtT4' '*, 6 djjl^,5*&" 7%.%<%<)2)D)D$-$:$:  $dD00r%c tjd|d}|r|sgddfSi}d|vr1 t|dtrt j |dn|d}|jdd}|jdd}ddlm }d d tj||d||t j|d } |t| g||fS#tj $ri}YwxYw) aA Transform Bedrock toolUse event to OpenAI format. Args: event: Bedrock toolUse event current_output_item_id: Current output item ID current_response_id: Current response ID Returns: Tuple of (events, tool_call_id, tool_name) for tracking zHandling toolUsetoolUser]input toolUseIdtoolNamer)castz%response.function_call_arguments.doner)rrr rrcall_idr arguments)rrrr"r|rrrtypingrDrr;r}r ) rSrcrrtool_use tool_input tool_call_id tool_namerDfunction_call_events r&transform_tool_use_eventz.BedrockRealtimeConfig.transform_tool_use_events " /0 *%-@r2:  h  >HRYIZ\_>`TZZ(9:fnovfw 'll;; #<< B7  < /.-#J/ 6 &(; < =    +''   s0C C! C!c tjdg}|jdi}|jddk(rtt j }|jdd}|jdd}dd |j |d d d |d d diddii}|jtj|dd|j |t|tr|ntj|dii}|jtj|dd|j |dii} |jtj| |S)a Transform conversation.item.create with tool result to Bedrock format. Args: json_message: OpenAI conversation.item.create message with tool result Returns: List of Bedrock format messages (JSON strings) z1Handling conversation.item.create for tool resultrrrrEr]rrcrFTOOLrrir9)rBrr)rrrrrrtoolResultInputConfiguration toolResultrrr) rrrr"r:r;r<rr|r}r) rSrrrtool_content_namerErtool_content_start tool_resulttool_content_ends r&rzJBedrockRealtimeConfig.transform_conversation_item_create_tool_result_event(s_ PQ%'"&&vr2 88F 5 5'*8>>+;'< !XXi4G HHXr2F"&*&6&6'8', & &)0$*7BL6Q9 % )  OODJJ'9: ; &*&6&6'8.8.EF4::V\K]#"K OODJJ{3 4 &*&6&6'8#'  OODJJ'78 9r%!realtime_response_transform_inputc  tj|}|jd}|jd}|jd } |jd } |jd } |jd } g} |jdi}d|vrtjddi} nxd|vr-|j|||| \}}}} } | j|nGd|vr*|j|||| \}} | j|nd|vr%|j|||}| j|nd|vrw|j|||| | \}} | j|tj!|dj"dk(r|j%|| \}}}} | j|nud|vr@|j'|||\}}}| j|t j(d||n1d|vsd|vr)|j+||| \}}}} | j|| ||| | |jd | | dS#tj$rt|tr|ddj ddn|dd}t jd|g|jd|jd|jd |jd |jd |jd |jd dcYSwxYw)ab Transform Bedrock Nova Sonic response to OpenAI realtime format. Args: message: Bedrock format message (JSON string) model: Model ID logging_obj: Logging object realtime_response_transform_input: Current state Returns: Transformed response with updated state Nrzutf-8replace)errorsrrrrrcurrent_item_chunksrr)r rrrrrZrrrcrd configuredTrrr&rEND_TURNr@zTool use event: %s (ID: %s)r completionEnd)r|rrrbytesrrrrr}rrr$r)r4rmodel_validaterr6rMrr7)rSrrVrrVrmessage_previewrrrrrrrrcevents done_eventsrJrKs r&transform_realtime_responsez1BedrockRealtimeConfig.transform_realtime_responsegs& "&**W"5L$"C!F!FG_!`?CCDYZ"C"G"GHa"b@DDE[\>BBCWX(I(M(MNm(n%?A$''4 U ",0JJ d7K,L ) u $22#&'   #&'"  $ $V , U "+/+K+K&#$ , (F(  $ $V , e #66u>TVijF  $ $V , U "+/+K+K&#"$ , (F(  $ $V , //l0CDOOS]] ../BD[\ *'&!((5 % .2.K.K-/B/ +FL)  $ $V ,  !> < X E !_%= //7JLcd  &#"  $ $V ,*&<#6$8'>#D#H#HI^#_"4-J  A## CMgW\C] $$WY$?cjkolocp   " "#= O*K*O*OPh*i'H'L'LMb'c(I(M(MNd(e+L+P+PQj+k'H'L'LMb'c&G&K&KL`&a1R1V1VWv1w    sICL  L )N)T)/rr r!__doc__rTdictr"rZr^boolr`listrr{intrrrrrrrrrrLiteLLMLoggingObjrrrrrtupler rrrr$r)r4r7r6rMrr^rrrcr$r%r&r1r15s3H ,DDsTz]atC#PT*`c,Z3,ZtDzD?P,Z\_,Z\T tDz0-S-T-]`-&y4yDIyvAdAtTWyAFdtTWy6BTBdSViBH.D.T#Y.` $s) " D T#Y S B59 ((((+Tz ( c (\(,  ' I$  %     '   +  (,    '  I$  +  g g !4Zg !$d g "%t g  !" d  d  d $    g R(2(2!$d (2!4Z (2 ##>?$F (2 t()40K+Lt+SS T (2T!!!$d !!4Z ! " # !Fd'd'!$d d'!4Z d'  $J d' ##>?$F d' t()40K+Lt+SS Td'LXX!4ZX"%t X  !" d  d $   X4 1 4Z 1"%t 1  !" d  d $   1D5 5 !$d 5 !4Z 5 t()33 4 5 n=QU=Z^_bZc=~~ u~ ~ ' ~ ,J ~ # ~ r%r1)1rdr7r|rr:rGrrpydanticrlitellm._loggingr litellm._uuid*litellm.litellm_core_utils.litellm_loggingrri-litellm.llms.base_llm.realtime.transformationr +litellm.llms.bedrock.realtime.trigger_audior litellm.types.llms.openair r r rrrrrrrrrrlitellm.types.realtimerrr litellm.utilsrrr(r#r*r^r+r-r/r1r$r%r&rts  +SLI *" "*/.(G!(KK!&'E'J!KK"'(F(J"K%K"&%&p .p r%