+ ~j\L^RIHt^RIt^RIt^RIt^RIHt^RIHt^RI H t ^RI t ^RI t ^RIHtHt^RIHt^RIHtHt^R IHt^R IHt^R IHtR t]!R R44t!RR]P<P>4t!RR]P<P@4t R#)) annotationsN) dataclass)Path)Literal)agentsrtc)utils) NOT_GIVEN NotGivenOr)is_given) onnx_modelloggerg?c^]tRt^)t$R]R&R]R&R]R&R]R&R]R&R]R&R]R &R tR #) _VADOptionsfloatmin_speech_durationmin_silence_durationprefix_padding_durationmax_buffered_speechactivation_thresholddeactivation_thresholdint sample_rateN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__ro/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/plugins/silero/vad.pyrr)s,""!!r"rca]tRt^4tRt]RRRRRRRR R RR R R RR]R]R]/ RRll4tRV3Rllt] RRl4t ] RRl4t RRlt R]R]R]R]R ]R]/RRllt RtV;t#)VADz Silero Voice Activity Detection (VAD) class. This class provides functionality to detect speech segments within audio data using the Silero VAD model. rg?rg?rg?rgN@rri> force_cpuTonnx_file_pathrpadding_durationcDV^8dQhRRRRRRRRRRRRR R R R R RRRRR/ #)rrrrrrrzLiteral[8000, 16000]r&boolr'zNotGivenOr[Path | str]rNotGivenOr[float]r(returnr%r)formats"r# __annotate__VAD.__annotate__<sQ/Q/#Q/$ Q/ "' Q/ # Q/$Q/*Q/Q//Q/!2Q/,Q/ Q/r"c  V\P9d \R4h\V 4'd\P !R4T p\V 4'dV ^8:d \R4h\P !Yx;'gRR7p \TTTTTT ;'g\VR, R4VR7p V!WR 7#) a Load and initialize the Silero VAD model. This method loads the ONNX model and prepares it for inference. When options are not provided, sane defaults are used. **Note:** This method is blocking and may take time to load the model into memory. It is recommended to call this method inside your prewarm mechanism. **Example:** ```python def prewarm(proc: JobProcess): proc.userdata["vad"] = silero.VAD.load() async def entrypoint(ctx: JobContext): vad = (ctx.proc.userdata["vad"],) # your agent logic... if __name__ == "__main__": cli.run_app(WorkerOptions(entrypoint_fnc=entrypoint, prewarm_fnc=prewarm)) ``` Args: min_speech_duration (float): Minimum duration of speech to start a new speech chunk. min_silence_duration (float): At the end of each speech, wait this duration before ending the speech. prefix_padding_duration (float): Duration of padding to add to the beginning of each speech chunk. max_buffered_speech (float): Maximum duration of speech to keep in the buffer (in seconds). activation_threshold (float): Threshold to consider a frame as speech. sample_rate (Literal[8000, 16000]): Sample rate for the inference (only 8KHz and 16KHz are supported). onnx_file_path (Path | str | None): Path to the ONNX model file. If not provided, the default model will be loaded. This can be helpful if you want to use a previous version of the silero model. force_cpu (bool): Force the use of CPU for inference. deactivation_threshold (float): Negative threshold (noise or exit threshold). If model's current state is SPEECH, values BELOW this value are considered as NON-SPEECH. Default is max(activation_threshold - 0.15, 0.01). padding_duration (float | None): **Deprecated**. Use `prefix_padding_duration` instead. Returns: VAD: An instance of the VAD class ready for streaming. Raises: ValueError: If an unsupported sample rate is provided. z4Silero VAD only supports 8KHz and 16KHz sample ratesz`padding_duration is deprecated and will be removed in 1.5.0, use prefix_padding_duration insteadz-deactivation_threshold must be greater than 0N)r'g333333?g{Gz?)rrrrrrr)sessionopts) r SUPPORTED_SAMPLE_RATES ValueErrorr rwarningnew_inference_sessionrmax) clsrrrrrrr&r'rr(r2r3s &$$$$$$$$$$ r#loadVAD.load;sx j?? ?ST T $ % % NNr '7 # * + +0F!0KLM M229McMc_cd 3!5$; 3!5#9#c#cSAUX\A\^b=c# 7..r"c$V^8dQhRRRRRR/#)r*r2zonnxruntime.InferenceSessionr3rr-Noner)r.s"r#r/r0s* 5 5. 5 5  5r"c <\SV`\PP RR7R7WnW n\P\,!4Vn R#)gMb?)update_interval) capabilitiesN) super__init__rvadVADCapabilities _onnx_session_optsweakrefWeakSet VADStream_streams)selfr2r3 __class__s&$$r#rB VAD.__init__sF fjj&@&@QV&@&WX$  24 r"cV^8dQhRR/#r*r-strr)r.s"r#r/r0ssr"c R#)silerorrKs&r#model VAD.modelsr"cV^8dQhRR/#rOr)r.s"r#r/r0s#r"c R#)ONNXrrSs&r#provider VAD.providersr"cV^8dQhRR/#)r*r-rIr)r.s"r#r/r0s r"c  \VVP\P!VPVPP R74pVP PV4V#)z Create a new VADStream for processing audio data. Returns: VADStream: A stream object for processing audio input and detecting speech. ) onnx_sessionr)rIrFr OnnxModelrErrJadd)rKstreams& r#r` VAD.streamsT  JJ  !//TZZ=S=S   &! r"c4V^8dQhRRRRRRRRRRRRRR /# r*rr,rrrrrr-r=r)r.s"r#r/r0sR++/+0 + "3 + / +0+!2+ +r"c  \V4'dWPn\V4'dW Pn\V4'dW0Pn\V4'dW@Pn\V4'dWPPn\V4'dW`PnVPFpVPVVVVVVR7K R#)aN Update the VAD options. This method allows you to update the VAD options after the VAD object has been created. Args: min_speech_duration (float): Minimum duration of speech to start a new speech chunk. min_silence_duration (float): At the end of each speech, wait this duration before ending the speech. prefix_padding_duration (float): Duration of padding to add to the beginning of each speech chunk. max_buffered_speech (float): Maximum duration of speech to keep in the buffer (in seconds). activation_threshold (float): Threshold to consider a frame as speech. )rrrrrrN) r rFrrrrrrrJupdate_options)rKrrrrrrr`s&$$$$$$ r#reVAD.update_optionss, ' ( (-@JJ * ( ) ).BJJ + + , ,1HJJ . ' ( (-@JJ * ( ) ).BJJ + * + +0FJJ -mmF  ! !$7%9(?$7%9'= " $r")rErFrJ)rrrr__doc__ classmethodr r:rBpropertyrTrYr`rer! __classcell__rLs@r#r%r%4s  Q/&*Q/'+ Q/ *- Q/ &* Q/'*Q/-2Q/Q/2;Q/5>Q//8Q/Q/f 5 5"+2;+3< + 6? + 2; +3<+5>++r"r%c a]tRt^tRV3RlltR]R]R]R]R]R]/R R llt]PP] R 7R R l4t Rt V;t #)rIc(V^8dQhRRRRRRRR/#) r*rCr%r3rrTzonnx_model.OnnxModelr-r=r)r.s"r#r/VADStream.__annotate__s* ) )C ){ );O )TX )r"c <\SV`V4W#uVnVn\P !4Vn\P!RR7Vn ^Vn RVn RVn ^Vn R#)gffffff?)alphaNF)rArBrF_modelasyncioget_event_loop_loopr ExpFilter _exp_filter_input_sample_rate_speech_buffer_speech_buffer_max_reached_prefix_padding_samples)rKrCr3rTrLs&&&&r#rBVADStream.__init__s_ "& DK++-  ??6"#15*/''($r"rrrrrrc4V^8dQhRRRRRRRRRRRRRR /#rcr)r.s"r#r/rnsR3838/380 38 "3 38 / 38038!238 38r"c lVPPp\V4'dWPn\V4'dW Pn\V4'dW0Pn\V4'dW@Pn\V4'dWPPn\V4'dW`PnVP'dVPfQh\VPP VP,4Vn VPP\VPPVP,4VP,4VPPV8d RVn R#R#R#)a Update the VAD options. This method allows you to update the VAD options after the VAD object has been created. Args: min_speech_duration (float): Minimum duration of speech to start a new speech chunk. min_silence_duration (float): At the end of each speech, wait this duration before ending the speech. prefix_padding_duration (float): Duration of padding to add to the beginning of each speech chunk. max_buffered_speech (float): Maximum duration of speech to keep in the buffer (in seconds). activation_threshold (float): Threshold to consider a frame as speech. deactivation_threshold (float): Negative threshold (noise or exit threshold). If model's current state is SPEECH, values BELOW this value are considered as NON-SPEECH. NF)rFrr rrrrrrwrxrrzresizery)rKrrrrrrold_max_buffered_speechs&$$$$$$ r#reVADStream.update_optionssD.#'**"@"@ ' ( (-@JJ * ( ) ).BJJ + + , ,1HJJ . ' ( (-@JJ * ( ) ).BJJ + * + +0FJJ -  " " "&&2 22+. 22T5L5LL,D (    & &DJJ22T5L5LLM../  zz--0GG27/H #r"rcV^8dQhRR/#r*r-r=r)r.s"r#r/rn#sFF$Fr"c aa"\P!SPP\PR7p^oRpRpRp^pRpRpRp.p .p Rp Rp Rp SP RjxL p\ V\P4'gK,SP'Eg&VPSn \SPPSP,4Sn\P!\SPPSP,4SP,\P R7SnSPSPP8wdP\P$!SPSPP\P&P(R7p M4SPVP8wd\*P,!R4EKSP"fQhV P/V4V e"V P1V P3V44MV P/V4\4P6!4p\9V Uu.uFpVP:NK up4pVSPP8dEKH\<P>!V 4p\<P>!V 4p\P@!VPBRSPP\PD!\P 4PFV\PR7SPHPKRSPV4GRjxL pSPLPORVR 7pSPPSPP, pVSPP, pVV, pSPSPP, pSPPV,V ,p\V4pVV, p \QSP"4S, p\SVV4pV^8d.VPBRVSP"SSV,%SV, oM/SPT'gRSn*\*PV!R 4\4P6!4V, p\GRV V,V, 4p V\X8d\*PV!R R V /R 7RVV3RllpRVV3RllpV'd VV, pM VV, pSPZP]\^P`Pc\^P`PdPfVVVVVV\P!VPBRVPi4SP^VR7.VVVR7 4VSPPj8g$V'dVSPPl8dVV, pRpV'gVSPPn8dnRpRpTpSPZP]\^P`Pc\^P`PdPpVVVVV!4.RR74MVV, pRpV'gV!4V'dVSPPr8dRpTpSPZP]\^P`Pc\^P`PdPtVVV\GRW8, 4V!4.RR74RpV!4.p .p \QVPB4V, ^8daVPBVRPi4pV P/\P!VSP^\QV4^,R74\QVPB4SPP, ^8gEK VPBSPPRPi4pV P/\P!VSPP^\QV4^,R74EKELxuupiELqEDR#5i))dtypeFgN) input_rate output_ratequalityz3a frame with another sample rate was already pushedT)outrg?)expsamplezOmax_buffered_speech reached, ignoring further data for the current speech inputz!inference is slower than realtimedelay)extracV^8dQhRR/#rr)r.s"r#r/*VADStream._main_task..__annotate__s G GT Gr"c<SPfQhSSP8:dR#SPSSP, SpRSnVSPRSP%SPoR#)NF)rxrzry) padding_datarKspeech_buffer_indexs r#_reset_write_cursor1VADStream._main_task.._reset_write_cursorsv..:::*d.J.JJ#'#6#6+d.J.JJM`$L7._copy_speech_buffersU..:::"&"5"56J7J"K"S"S"UK>>$($;$;%&,?( r")rrrr) type samples_index timestampsilence_durationspeech_duration probabilityinference_durationframesspeakingraw_accumulated_silenceraw_accumulated_speech)rrrrrrr);npemptyrqwindow_size_samplesfloat32 _input_ch isinstancerrrwrrrFrrzrint16rxAudioResamplerAudioResamplerQualityQUICKrerrorappendextendpushtime perf_countersumrr combine_framesdivideriinfor8rtrun_in_executorrvapplylenminryr6SLOW_INFERENCE_THRESHOLD _event_ch send_nowaitrrCVADEvent VADEventTypeINFERENCE_DONErrrrSTART_OF_SPEECHr END_OF_SPEECH)rKinference_f32_data pub_speakingpub_speech_durationpub_silence_durationpub_current_sample pub_timestampspeech_threshold_durationsilence_threshold_duration input_framesinference_frames resamplerinput_copy_remaining_fractextra_inference_time input_frame start_timeframeavailable_inference_samplesinference_framepwindow_durationresampling_ratioto_copy to_copy_intavailable_spaceto_copy_bufferrrrrrsf @r# _main_taskVADStream._main_task"sXXdkk&E&ERZZX#$ !" $'!%("-/ 13/3 &)""!%o o +k3>>::****5*A*A'03JJ669P9PP0,')hh 669P9PPQ223(('# **djj.D.DD!$ 2 2#'#:#:$(JJ$:$: # 9 9 ? ?!I ((K,C,CC RS&&2 22    ,$!'' {(CD '' 4!..0 .19'8886:D3NNi&*%6%6%8:%E"'*(+==O($&(@@NN;&(<= G G   '?:'(O;(**JJ''#ZZ44CC&8"/)=(;$%+=NN%0%5%5l{%C%K%K%M,0,C,C-.4?  ".0J/H%(. 777 Q)J)J%J-@-14.'4 8V8VV+/L3602K/ NN66 & 3 3)/)@)@)P)P2D.;5I4G,?,A+B-1!4!" //A.03-'+-%6$**:Y:YY', /I,22"JJ//%+ZZ%<%<%J%J.@*71E03$')<)Y1")<(='>).0  /2++- " #% {''(;6:&++KL9AACD ''!%(,(?(?)*03D Q ++,t{{/N/NNQRR*// 0O0O0QRZZ\D$++!%(, (>(>)*03D Q Qo ZN"\}"0sA!c0%c,)c!*c,-6c0$Gc03c$ C0c08c)9Ec0>Bc0Cc0+-c0Bc05c0Ec0 Bc0!c,$c0,c0)rvrwrtrqrFrzrxry)rrrrrBr rerr log_exceptionsrrr!rjrks@r#rIrIsw ) )382;383< 38 6? 38 2; 383<385>38j \\   /F0Fr"rI)! __future__rrrrrG dataclassesrpathlibrtypingrnumpyr onnxruntimelivekitrrlivekit.agentsr livekit.agents.typesr r livekit.agents.utilsr r logrrrrCr%rIrr"r#rs# ! *  j&**..jZH $$Hr"