qidZddlZddlZddlZddlmZmZddlmZddl m Z m Z m Z m Z ddlmZddlmZddlmZdd lmZmZmZmZmZmZmZmZmZdd lmZm Z m!Z!m"Z"dd l#m$Z$dd l%m&Z&dd l'm(Z(ddl)m*Z* ddl+m,Z-ddl.m/Z/Gdde4eZ5Gdde4eZ6eGdde Z7Gdde$Z8y#e0$r7Z1ejdde1ejdde3de1dZ1[1wwxYw)z4Deepgram Flux speech-to-text service implementation.N) dataclassfield)Enum)AnyAsyncGeneratorDictOptional) urlencode)logger) BaseModel) CancelFrameEndFrame ErrorFrameFrameInterimTranscriptionFrame StartFrameTranscriptionFrameUserStartedSpeakingFrameUserStoppedSpeakingFrame) NOT_GIVEN STTSettings _NotGiven_warn_deprecated_param)WebsocketSTTService)Language)time_now_iso8601) traced_stt)connect)Statez Exception: zNIn order to use Deepgram Flux, you need to `pip install pipecat-ai[deepgram]`.zMissing module: c$eZdZdZdZdZdZdZdZy)FluxMessageTypezDeepgram Flux WebSocket message types. These are the top-level message types that can be received from the Deepgram Flux WebSocket connection. ConnectedErrorTurnInfoConfigureSuccessConfigureFailureN) __name__ __module__ __qualname____doc__RECEIVE_CONNECTEDRECEIVE_FATAL_ERROR TURN_INFOCONFIGURE_SUCCESSCONFIGURE_FAILURET/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/deepgram/flux/stt.pyr!r!.s& $!I**r1r!c$eZdZdZdZdZdZdZdZy) FluxEventTypezDeepgram Flux TurnInfo event types. These events are contained within TurnInfo messages and indicate different stages of speech processing and turn detection. StartOfTurn TurnResumed EndOfTurnEagerEndOfTurnUpdateN) r'r(r)r* START_OF_TURN TURN_RESUMED END_OF_TURNEAGER_END_OF_TURNUPDATEr0r1r2r4r4<s# "M LK( Fr1r4ceZdZUdZedZedzezed<edZ edzezed<edZ e dzezed <ed Z e ezed <ed Zedzezed <y)DeepgramFluxSTTSettingsaSettings for DeepgramFluxSTTService. Parameters: eager_eot_threshold: EagerEndOfTurn/TurnResumed threshold. Off by default. Lower values = more aggressive (faster response, more LLM calls). Higher values = more conservative (slower response, fewer LLM calls). eot_threshold: End-of-turn confidence required to finish a turn (default 0.7). eot_timeout_ms: Time in ms after speech to finish a turn regardless of EOT confidence (default 5000). keyterm: Keyterms to boost recognition accuracy for specialized terminology. min_confidence: Minimum confidence required to create a TranscriptionFrame. ctSNrr0r1r2z DeepgramFluxSTTSettings.YsR[r1)default_factoryNeager_eot_thresholdctSrBrCr0r1r2rDz DeepgramFluxSTTSettings.ZsIr1 eot_thresholdctSrBrCr0r1r2rDz DeepgramFluxSTTSettings.[s9r1eot_timeout_msctSrBrCr0r1r2rDz DeepgramFluxSTTSettings.\sir1keytermctSrBrCr0r1r2rDz DeepgramFluxSTTSettings.]sYr1min_confidence)r'r(r)r*rrFfloatr__annotations__rHrJintrLlistrNr0r1r2r@r@Js 5:J[4\ 1\.3DU.VM54<)+V-2CT-UNC$J*U %6G HGTI H/4EV/WNEDL9,Wr1r@c|eZdZUdZeZeed<hdZGddeZ dddddddd dd d e d e d e e de e de e de de ede e de de effdZfdZfdZd>defdZdZdZdZd?dZdee fd Zde fd!Zd"edee efffd# Zd$effd% Zd$e ffd& Z!d$e"ffd' Z#d(e$de%e&dffd)Z'd*Z(e) d@d+e d,e d-e e*fd.Z+d/Z,d0e-e efde fd1Z.d2Z/d0e-e effd3Z0d4Z1d0e-e effd5Z2d0e-e effd6Z3d+e fd7Z4d8e fd9Z5de efd:Z6d+e d0e-e effd;Z7d+e d0e-e effd<Z8d+e fd=Z9xZ:S)ADeepgramFluxSTTServiceanDeepgram Flux speech-to-text service. Provides real-time speech recognition using Deepgram's WebSocket API with Flux capabilities. Supports configurable models, VAD events, and various audio processing options including advanced turn detection and EagerEndOfTurn events for improved conversational AI performance. Event handlers available (in addition to WebsocketSTTService events): - on_speech_started(service): Deepgram detected start of speech - on_utterance_end(service): Deepgram detected end of utterance - on_end_of_turn(service): Deepgram detected end of turn (EOT) - on_eager_end_of_turn(service): Deepgram predicted end of turn (EagerEOT) - on_turn_resumed(service): User resumed speaking after EagerEOT Example:: @stt.event_handler("on_end_of_turn") async def on_end_of_turn(service): ... _settings>rLrHrJrFceZdZUdZdZeeed<dZeeed<dZ ee ed<gZ e ed<dZ eeed<gZe ed<dZeeed <y) "DeepgramFluxSTTService.InputParamsaConfiguration parameters for Deepgram Flux API. .. deprecated:: 0.0.105 Use ``settings=DeepgramFluxSTTSettings(...)`` instead. Parameters: eager_eot_threshold: Optional. EagerEndOfTurn/TurnResumed are off by default. You can turn them on by setting eager_eot_threshold to a valid value. Lower values = more aggressive EagerEndOfTurning (faster response, more LLM calls). Higher values = more conservative EagerEndOfTurning (slower response, fewer LLM calls). eot_threshold: Optional. End-of-turn confidence required to finish a turn (default 0.7). Lower values = turns end sooner (more interruptions, faster responses). Higher values = turns end later (fewer interruptions, more complete utterances). eot_timeout_ms: Optional. Time in milliseconds after speech to finish a turn regardless of EOT confidence (default 5000). keyterm: List of keyterms to boost recognition accuracy for specialized terminology. mip_opt_out: Optional. Opts out requests from the Deepgram Model Improvement Program (default False). tag: List of tags to label requests for identification during usage reporting. min_confidence: Optional. Minimum confidence required confidence to create a TranscriptionFrame NrFrHrJrL mip_opt_outtagrN)r'r(r)r*rFr rOrPrHrJrQrLrRrXboolrYrNr0r1r2 InputParamsrWzsc ,04Xe_3)- x-(, ,&* Xd^*T*..r1r[z wss://api.deepgram.com/v2/listenNlinear16T) url sample_raterXmodel flux_encodingrYparamsshould_interruptsettingsapi_keyr]r^rXr_r`rYrarbrcc tdtjdddgd} |tdtd|| _|tdt| s|j | _|j | _|j| _|jxsg| _|jr| |j}|j| _ |j |j}| | j| t |8d |d| d| ||_||_| |_||_||_|xsg|_d|_d|_|j/d|j/d |j/d |j/d |j/d t1j2|_d|_d|_d|_y)aInitialize the Deepgram Flux STT service. Args: api_key: Deepgram API key for authentication. Required for API access. url: WebSocket URL for the Deepgram Flux API. Defaults to the preview endpoint. sample_rate: Audio sample rate in Hz. If None, uses the pipeline sample rate. mip_opt_out: Opt out of the Deepgram Model Improvement Program. model: Deepgram Flux model to use for transcription. .. deprecated:: 0.0.105 Use ``settings=DeepgramFluxSTTSettings(model=...)`` instead. flux_encoding: Audio encoding format required by Flux API. Must be "linear16". Raw signed little-endian 16-bit PCM encoding. tag: Tags to label requests for identification during usage reporting. params: InputParams instance containing detailed API configuration options. .. deprecated:: 0.0.105 Use ``settings=DeepgramFluxSTTSettings(...)`` instead. should_interrupt: Determine whether the bot should be interrupted when Flux detects that the user is speaking. settings: Runtime-updatable settings. When provided alongside deprecated parameters, ``settings`` values take precedence. **kwargs: Additional arguments passed to the parent WebsocketSTTService class. Examples: Basic usage with default parameters:: stt = DeepgramFluxSTTService(api_key="your-api-key") Advanced usage with custom parameters:: stt = DeepgramFluxSTTService( api_key="your-api-key", settings=DeepgramFluxSTTSettings( model="flux-general-en", eager_eot_threshold=0.5, eot_threshold=0.8, keyterm=["AI", "machine learning", "neural network"], tag=["production", "voice-agent"], ), ) zflux-general-enN)r_languagerFrHrJrLrNr_raF)r^reconnect_on_errorrcon_start_of_turnon_turn_resumedon_end_of_turnon_eager_end_of_turn on_updater0)r@rENrr_rFrHrJrLrYrNrX apply_updatesuper__init___api_key_url_should_interrupt _encoding _mip_opt_out_tag_websocket_url _receive_task_register_event_handlerasyncioEvent_connection_established_event_last_stt_time_watchdog_task_user_is_speaking)selfrdr]r^rXr_r`rYrarbrckwargsdefault_settings __class__s r2rpzDeepgramFluxSTTService.__init__sN3#[[ $    "7,CW M%*  "   "8-D E7=7Q7Q 4171E1E .282G2G /+1>>+?R (::#+ **C282G2G /%%1"("4"4K    ) )( 3  #$%      !1&'I2 "! $$%78 $$%67 $$%56 $$%;< $$[1-4]]_*#"!&r1crKt|d{|jd{y77w)zConnect to WebSocket and start background tasks. Establishes the WebSocket connection to the Deepgram Flux API and starts the background task for receiving transcription results. N)ro_connect_connect_websocket)rrs r2rzDeepgramFluxSTTService._connects5 g   %%''' !'s737577cKt|d{ |jd{d|_y7%7#t$r)}|j d||d{7Yd}~9d}~wwxYw#d|_wxYww)zDisconnect from WebSocket and clean up tasks. Gracefully disconnects from the Deepgram Flux API, cancels background tasks, and cleans up resources to prevent memory leaks. NUnknown error occurred:  error_msg exception)ro _disconnect_disconnect_websocket Exception push_error _websocket)rers r2rz"DeepgramFluxSTTService._disconnect(s g!### #,,. . . #DO $ / Y//.Fqc,JVW/X X X Y#DOsXB;B?=? B? A1A,!A$"A,'A4,A11A44 A==B duration_secscKd}d}t|j|z}d||z|zz}|jj|d{y7w)zCSend a block of silence of the specified duration (default 500 ms).N)rQr^rsend)rr sample_width num_channels num_samplessilences r2 _send_silencez$DeepgramFluxSTTService._send_silence8sQ  $**]:; [<7,FGoo""7+++sAAA Ac&K|jr|jjtjurt j }|j rd|jrX||jz dkDrFtjd|jd{t j |_tjdd{|jr(|jjtjuryyyy7q7=w)N?z0Sending silence to Flux to prevent dangling taskg?) rstaterOPENtime monotonicrr}r warningrrzsleep)rnows r2_watchdog_task_handlerz-DeepgramFluxSTTService._watchdog_task_handler@soo$//"7"75::"E.."C%%$*=*=#H[H[B[^aBaQR((***&*nn&6#--$ $ $oo$//"7"75::"Eo"Eo + %s*BDD 5DD6D DDcbK |jr'|jjtjury|jj d|_t|jdd|jid{|_|jjjjDcic]\}}|jds||}}}tj|d|d|j s/|j#|j%|j&|_|j(s$|j#|j+|_tjd |jj-d{tjd |j/d d{y7Icc}}w7<7#t0$rL}|j3d || d{7d|_|j/d|d{7Yd}~yd}~wwxYww)aEstablish WebSocket connection to API. Creates a WebSocket connection to the Deepgram Flux API using the configured URL and authentication headers. Handles connection errors and reports them through the event handler system. NF AuthorizationzToken )additional_headerszdg-z0: Websocket connection initialized: {"headers": }z7WebSocket connected, waiting for server confirmation...z$Connected to Deepgram Flux Websocket on_connectedrron_connection_error)rrrrr|clearrwebsocket_connectrwrqresponseheadersitems startswithr debugrx create_task_receive_task_handler _report_errorr~rwait_call_event_handlerrr)rkvrrs r2rz)DeepgramFluxSTTService._connect_websocketKs" J4??#8#8EJJ#F  . . 4 4 6%*D "$5##$3vdmm_5M#N%DO "&!9!9!A!A!G!G!IAQ\\Z_M`1G LLD6!RSZR[[]^ _%%%)%5%5..t/A/AB&" &&&*&6&6t7R7R7T&U# LLR S4499; ; ; LL? @**>: : :1 " < : J//.Fqc,JVW/X X X"DO**+@QCI I I JsH/2GH/A GG :G<G G B;GG-GGG H/ G GG H, H'9G<:"H'HH'"H/'H,,H/c$K |jr,|j|jdd{d|_|jr3|j|jdd{d|_d|_|jj |j d{|jrO|jd{tjd|jjd{d|_|jdd{y7777b7-#t$r)}|jd||d{7Yd}~Xd}~wwxYw7D#d|_|jdd{7wxYww)zClose WebSocket connection and clean up state. Closes the WebSocket connection to the Deepgram Flux API and stops all metrics collection. Handles disconnection errors gracefully. g@)timeoutNz*Disconnecting from Deepgram Flux WebsocketzError closing websocket: ron_disconnected)rx cancel_taskr~r}r|rstop_all_metricsr_send_close_streamr rcloserrr)rrs r2rz,DeepgramFluxSTTService._disconnect_websocketvsc  >!!&&t'9'93&GGG%)"""&&t':':C&HHH&*#&*#  . . 4 4 6'') ) )--/// IJoo++---#DO**+<= = =%HI *0- Z//.Gs,KWX/Y Y Y Z >#DO**+<= = =sF,D3D)7D3(D+)?D3(D-)#D3 D/ 6D3D1D3F#E($F)D3+D3-D3/D31D33 E%<E EE E* E%%E*(F*F F F  Freturnc4K |jrPtjdddi}|jjt j |d{yy7#t $r)}|jd||d{7Yd}~yd}~wwxYww)zSends a CloseStream control message to the Deepgram Flux WebSocket API. This signals to the server that no more audio data will be sent. z,Sending CloseStream message to Deepgram Fluxtype CloseStreamNzError sending closeStream: r)rr rrjsondumpsrr)rmessagers r2rz)DeepgramFluxSTTService._send_close_streams  \ KL!=1oo**4::g+>???@ \//.I!,MYZ/[ [ [ \sMBAA#A!A#B!A## B,BBB BBBfieldscKddi}d|vr|jj|d<i}d|vr|jj|d<d|vr|jj|d<d|vr|jj|d<|r||d<t j |d ||jjtj|d {y 7w) a/Send a Configure control message to update settings mid-stream. Builds a Configure JSON message containing only the fields that changed and sends it over the existing WebSocket connection. Args: fields: Set of changed field names to include in the message. r ConfigurerLkeytermsrHrFrJ thresholdsz: sending Configure message: N) rUrLrHrFrJr rrrrr)rrrrs r2_send_configurez&DeepgramFluxSTTService._send_configures$*;"7  "&.."8"8GJ %' f $*...*F*FJ ' F *040R0RJ, - v %+/>>+H+HJ' ( $.GL ! v:7)DEoo""4::g#6777sC CCCcy)zCheck if this service can generate processing metrics. Returns: True, as Deepgram service supports metrics generation. Tr0rs r2can_generate_metricsz+DeepgramFluxSTTService.can_generate_metricss r1deltaczKt||d{}|s|S|j|jz}|rK|jr?|jj t jur|j|d{|j|j|jz |S774w)a Apply a settings delta. Configure-able fields (keyterm, eot_threshold, eager_eot_threshold, eot_timeout_ms) are sent to Deepgram via a Configure WebSocket message. Other fields are stored but cannot be applied to the active connection. N) ro_update_settingskeys_CONFIGURE_FIELDSrrrrr _warn_unhandled_updated_settings)rrchangedconfigure_fieldsrs r2rz'DeepgramFluxSTTService._update_settingss077N"<<>D,B,BB DOO4I4IUZZ4W&&'78 8 8 --gllnt?U?U.UV8 9s"B;B7A-B;B93B;9B;framecKt||d{d|jjd|jd|j g}|jj (|jd|jj |jj(|jd|jj|jj(|jd|jj|j5|jdt|jj|jjD]}|jtd |i |jD]}|jtd |i |j d d j#||_|j'd{y77w) a?Start the Deepgram Flux STT service. Initializes the service by constructing the WebSocket URL with all configured parameters and establishing the connection to begin transcription processing. Args: frame: The start frame containing initialization parameters and metadata. Nzmodel=z sample_rate=z encoding=zeager_eot_threshold=zeot_threshold=zeot_timeout_ms=z mip_opt_out=rLrY?&)rostartrUr_r^rtrFappendrHrJrustrlowerrLr rvrrjoinrwr)rr url_paramsrL tag_valuers r2rzDeepgramFluxSTTService.startsgmE"""T^^))* +4++, -' ( >> - - 9    4T^^5W5W4XY Z >> ' ' 3   t~~/K/K.LM N >> ( ( 4   0M0M/NO P    (    S1B1B-C-I-I-K,LM N~~-- ?G   iG(<= > ? =I   i (:; < ="& 1SXXj-A,BCmmo; #: s"G3G.GG3(G1)G31G3ctKt||d{|jd{y77w)z]Stop the Deepgram Flux STT service. Args: frame: The end frame. N)rostoprrrrs r2rzDeepgramFluxSTTService.stops6 gl5!!!    " 848688ctKt||d{|jd{y77w)zbCancel the Deepgram Flux STT service. Args: frame: The cancel frame. N)rocancelrrs r2rzDeepgramFluxSTTService.cancels6 gnU###    $ raudiocK|jsy tj|_|j ||j d{dy7 #t $r}td|Yd}~yd}~wwxYww)aSend audio data to Deepgram Flux for transcription. Transmits raw audio bytes to the Deepgram Flux API for real-time speech recognition. Transcription results are received asynchronously through WebSocket callbacks and processed in the background. Args: audio: Raw audio bytes in linear16 format (signed little-endian 16-bit PCM). Yields: Frame: None (transcription results are delivered via WebSocket callbacks rather than as return values from this method). Raises: Exception: If the WebSocket connection is not established or if there are issues sending the audio data. Nr)error)rrrr}send_with_retryrrr)rrrs r2run_sttzDeepgramFluxSTTService.run_sttst$  "&.."2D &&ud.@.@A A A  B %=aS#AB B  s@A>8A A AA>A A;A61A>6A;;A>c@K|jd{y7w)z-Start TTFB and processing metrics collection.N)start_processing_metricsrs r2 start_metricsz$DeepgramFluxSTTService.start_metrics/s++---s  transcriptis_finalrfc Kyw)z+Handle a transcription result with tracing.Nr0)rrrrfs r2_handle_transcriptionz,DeepgramFluxSTTService._handle_transcription9s scH|jr |jStd)aQGet the current WebSocket connection. Returns the active WebSocket connection instance, raising an exception if no connection is currently established. Returns: The active WebSocket connection instance. Raises: Exception: If no WebSocket connection is currently active. zWebsocket not connected)rrrs r2_get_websocketz%DeepgramFluxSTTService._get_websocket@s! ???? "122r1datact|tstjdyd|vrtjdyy)a3Validate basic message structure from Deepgram Flux. Ensures the received message has the expected structure before processing. Args: data: The parsed JSON message data to validate. Returns: True if the message structure is valid, False otherwise. zMessage is not a dictionaryFrzMessage missing 'type' fieldT) isinstancedictr r)rrs r2_validate_messagez(DeepgramFluxSTTService._validate_messagePs9$% NN8 9   NN9 :r1cK|j23d{}t|tr0 tj|}|j |d{Itjdt|k7f7)#tj $r"}tjd|Yd}~d}~wt$r%}|jd||d{7d}~wwxYw6yw)aReceive and process messages from WebSocket. Continuously receives messages from the Deepgram Flux WebSocket connection and processes various message types including connection status, transcription results, turn information, and error conditions. Handles different event types such as StartOfTurn, EndOfTurn, EagerEndOfTurn, and Update events. NzFailed to decode JSON message: rrzReceived non-string message: ) rrrrloads_handle_messageJSONDecodeErrorr rrrrr)rrrrs r2_receive_messagesz(DeepgramFluxSTTService._receive_messageses"002 P P''3' ::g.D..t444!>tG}oNO P5++LL#B1#!FG //6Nqc4R^_/```3srC(C&A>C&C()BBB#C(>C&BC#B2-C(2 C#>CCCC##C(c,K|j|sy|jd} t|}|xtj k(r|jd{yxtjk(r|j|d{yxtjk(r|j|d{yxtjk(rt j|d|ytjk(ra|jdd}|jdd}d |d |}t j|d ||j!| d{yy#t$rt j d|xsdYywxYw707779w) a Handle a parsed WebSocket message from Deepgram Flux. Routes messages to appropriate handlers based on their type. Validates message structure before processing. Args: data: The parsed JSON message data from the WebSocket. NrzUnhandled message type: unknownz: Configure accepted: error_code descriptionzno descriptionzConfigure rejected: [z] z: )r)rgetr! ValueErrorr rr+_handle_connection_establishedr,_handle_fatal_errorr-_handle_turn_infor.infor/rr)rr message_typeflux_message_typerrrs r2rz&DeepgramFluxSTTService._handle_message}sg%%d+ xx'   / =   22299;;;444..t444***,,T222222 tf$:4&AB 22!XXlI> "hh}6FG 3J_handle_update)rrrrflux_event_types r2r z(DeepgramFluxSTTService._handle_turn_infos!XXlB/  +E2O ,,,00<<<+++//666***..z4@@@00044ZFFF%%))*555&  LL5eW= >   =6@F5s{$E  D)E E-E  E .E 8E9.E 'E(+E E E !D>;E =D>>E E E E  E cpKtjdd|_|jtd{|j r|j d{|jd{|jd|d{|rtjd|yy7v7T7>7&w)a\Handle StartOfTurn events from Deepgram Flux. StartOfTurn events are fired when Deepgram Flux detects the beginning of a new speaking turn. This triggers bot interruption to stop any ongoing speech synthesis and signals the start of user speech detection. The service will: - Send a BotInterruptionFrame upstream to stop bot speech - Send a UserStartedSpeakingFrame downstream to notify other components - Start metrics collection for measuring response times Args: transcript: maybe the first few words of the turn. zUser started speakingTNrhzStart of turn transcript: ) r rrbroadcast_framerrsbroadcast_interruptionrrtracerrs r2rz,DeepgramFluxSTTService._handle_start_of_turns  ,-!%""#;<<<  ! !--/ / /  """&&'9:FFF  LL5j\B C  = /"FsE5B6B.#B6B0B63B24B6 B4!B60B62B64B6rcrKtjd||jdd{y7w)amHandle TurnResumed events from Deepgram Flux. TurnResumed events indicate that speech has resumed after a brief pause within the same turn. This is primarily used for logging and debugging purposes and doesn't trigger any significant processing changes. Args: event: The event type string for logging purposes. zReceived event TurnResumed: riNr rr)rrs r2rz+DeepgramFluxSTTService._handle_turn_resumeds1  3E7;<&&'8999s -757c|jd}|rt|tsy|Dcgc]9}t|jdttfs)|jd;}}|syt |t |z Scc}w)zwCalculate the average confidence from transcript data. Return None if the data is missing or invalid. wordsN confidence)rrrRrOrQsumlen)rtranscript_datar$w confidencess r2_calculate_average_confidencez4DeepgramFluxSTTService._calculate_average_confidences  ##G,Jud3). $%*QUU<=PSXZ]R^2_AEE,   ;#k"222  s *BBc Ktjdd|_|j|}|jj r||jj kDrO|j t||jt|jj|dd{ntjd||j|d|jjd{|jd{|jtd{|j!d|d{y77V7@7%7 w)aHandle EndOfTurn events from Deepgram Flux. EndOfTurn events are fired when Deepgram Flux determines that a speaking turn has concluded, either due to sufficient silence or end-of-turn confidence thresholds being met. This provides the final transcript for the completed turn. The service will: - Create and send a final TranscriptionFrame with the complete transcript - Trigger transcription handling with tracing for metrics - Stop processing metrics collection - Send a UserStoppedSpeakingFrame to signal turn completion Args: transcript: The final transcript text for the completed turn. data: The TurnInfo message data containing event type, transcript and some extra metadata. zUser stopped speakingFT)result finalizedNz9Transcription confidence below min_confidence threshold: rj)r rrr+rUrN push_framer_user_idrrfrrstop_processing_metricsrrr)rrraverage_confidences r2rz*DeepgramFluxSTTService._handle_end_of_turns&$  ,-!&"??E~~,,0BT^^EbEb0b//"MM$&NN++"     NNKL^K_` ((T4>>;R;RSSS**,,,""#;<<<&&'7DDD%  T,<Ds[B&E(E)AE0E1EE  E%E &E?E EE E E Ec Ktjd||jt||jt |j j|d{|jd|d{y77w)aHandle EagerEndOfTurn events from Deepgram Flux. EagerEndOfTurn events are fired when the end-of-turn confidence reaches the EagerEndOfTurn threshold but hasn't yet reached the full end-of-turn threshold. These provide interim transcripts that can be used for faster response generation while still allowing the user to continue speaking. EagerEndOfTurn events enable more responsive conversational AI by allowing the LLM to start processing likely final transcripts before the turn is definitively ended. Args: transcript: The interim transcript text that triggered the EagerEndOfTurn event. data: The TurnInfo message data containing event type, transcript and some extra metadata. zEagerEndOfTurn - )r-Nrk) r rr/rr0rrUrfr)rrrs r2rz0DeepgramFluxSTTService._handle_eager_end_of_turnCs  ( 56$oo %  "''     &&'=zJJJ  Ks$A!B#B$B=B>BBczK|r3tjd||jd|d{yy7w)a2Handle Update events from Deepgram Flux. Update events provide incremental transcript updates during an ongoing turn. These events allow for real-time display of transcription progress and can be used to provide visual feedback to users about what's being recognized. The service stops TTFB (Time To First Byte) metrics when the first substantial update is received, indicating successful processing start. Args: transcript: The current partial transcript text for the ongoing turn. zUpdate event: rlNr"r s r2rz%DeepgramFluxSTTService._handle_updatepsA  LL>*6 7**; C C C  Ds 0;9;)r)rNrB);r'r(r)r*r@SettingsrPrr r[rr rQrZrRrprrrOrrrrrrrrrrrrrrrr rbytesrrrrrrrrrrrrr r r rrr+rrr __classcell__)rs@r2rTrT`s*'H&&]/i/F6%)&*#'"(,!%6:C'C' C' c] C' d^ C'}C'C'd^C'%C'C'23C'J(# ,, %)JV>: \8CH86d,CSRUX(&&P!!!+!5^E4K-H<.NR  )- 9A(9K  3 d38n*P0";$sCx.";H 1(d38n(&6DcN6>DcD2 : :33 -EC-EtCH~-E^+K#+KT#s(^+KZDsDr1rT)9r*rzrr dataclassesrrenumrtypingrrrr urllib.parser logurur pydanticr pipecat.frames.framesr rrrrrrrrpipecat.services.settingsrrrrpipecat.services.stt_servicerpipecat.transcriptions.languagerpipecat.utils.timer(pipecat.utils.tracing.service_decoratorsrwebsockets.asyncio.clientrrwebsockets.protocolrModuleNotFoundErrorrrrrr!r4r@rTr0r1r2rGs; (66"   `_<4/?,F) +c4 + C  XkX X*f D0f Dq,FLL;qc"#FLLab &qc* ++,s6 B66C2;2C--C2