GJjddlZddlZddlmZmZddlmZddlmZmZm Z m Z m Z ddl m ZddlmZddlmZddlmZmZmZmZmZmZmZddlmZmZmZddlm Z m!Z!dd l"m#Z#m$Z$dd l%m&Z&m'Z'm(Z(dd l)m*Z*m+Z+m,Z,m-Z-eGd d Z.eGddZ/eGddZ0eGddZ1eGddZ2eGddZ3eGdde1Z4eGddZ5eGddZ6eGddZ7Gd d!ejpZ9Gd"d#e9Z:Gd$d%e9Z;Gd&d'e9Z<Gd(d)e:Z=Gd*d+Z>y),N) dataclassfield)Path)CallableDictListOptionalUnion) tokenizer) AlignedResult AlignedTokenSentenceConfig merge_longest_common_subsequencemerge_longest_contiguoussentences_to_resulttokens_to_sentences)PreprocessArgs get_logmel load_audio)ConformerCacheRotatingConformerCache) Conformer ConformerArgs) AuxCTCArgsConvASRDecoderConvASRDecoderArgs) JointArgs JointNetwork PredictArgsPredictNetworkc8eZdZUeed<eeed<edzed<y)TDTDecodingArgs model_type durationsNgreedy)__name__ __module__ __qualname__str__annotations__listintdict_/Users/ahmed/devFolder/claude-voice/.venv/lib/python3.12/site-packages/parakeet_mlx/parakeet.pyr"r"sOCy 4Kr/r"ceZdZUedzed<y)RNNTDecodingArgsNr%r&r'r(r-r*r.r/r0r2r2" 4Kr/r2ceZdZUedzed<y)CTCDecodingArgsNr%r3r.r/r0r6r6'r4r/r6c@eZdZUeed<eed<eed<eed<eed<y)ParakeetTDTArgs preprocessorencoderdecoderjointdecodingN) r&r'r(rr*rrrr"r.r/r0r8r8,s     r/r8c@eZdZUeed<eed<eed<eed<eed<y)ParakeetRNNTArgsr9r:r;r<r=N) r&r'r(rr*rrrr2r.r/r0r?r?5s     r/r?c6eZdZUeed<eed<eed<eed<y)ParakeetCTCArgsr9r:r;r=N)r&r'r(rr*rrr6r.r/r0rArA>s   r/rAceZdZUeed<y)ParakeetTDTCTCArgsaux_ctcN)r&r'r(rr*r.r/r0rCrCFs r/rCc eZdZy)GreedyN)r&r'r(r.r/r0rFrFLsr/rFcFeZdZUdZeed<dZeed<dZeed<dZ eed<y) Beam beam_size?length_penaltypatiencegffffff?duration_rewardN) r&r'r(rJr,r*rLfloatrMrNr.r/r0rHrHQs*IsNEHe OU r/rHcPeZdZUeeZeeefed<ee Z e ed<y)DecodingConfig)default_factoryr=sentenceN) r&r'r(rrFr=r rHr*rrSr.r/r0rQrQYs)$)&$AHeFDL!A$^DHnDr/rQc0eZdZdZdedeffd ZedefdZ e dde jd e de efd Ze j e d d d d deezde j&d e deededeedefdZ dde ddeeefded e ddfdZxZS) BaseParakeetz)Base parakeet model for interface purposepreprocess_args encoder_argsc^t|||_||_t ||_yN)super__init__preprocessor_configencoder_configrr:)selfrVrW __class__s r0r[zBaseParakeet.__init__cs* #2 * . r/returnc|jj|jjz |jjzSrY)r]subsampling_factorr\ sample_rate hop_lengthr^s r0 time_ratiozBaseParakeet.time_ratioks@    2 2&&22 3&&11 2 r/decoding_configmelrhct)a Generate transcription results from the Parakeet model, handling batches and single input. Args: mel (mx.array): Mel-spectrogram input with shape [batch, sequence, mel_dim] for batch processing or [sequence, mel_dim] for single input. decoding_config (DecodingConfig, optional): Configuration object that controls decoding behavior and parameters for the generation process. Defaults to DecodingConfig(). Returns: list[AlignedResult]: List of transcription results with aligned tokens and sentences, one for each input in the batch. )NotImplementedError)r^rirhs r0generatezBaseParakeet.generatess "!r/Ng.@)dtyperhchunk_durationoverlap_durationchunk_callbackpathrmrnrorpct|}t||jj|}|,t ||j} |j | |dSt ||jjz } | |kr,t ||j} |j | |dSt||jjz} t||jjz} g} tdt || | z D]}t|| zt |}|||t |||z |jjkrn|||}t ||j}|j ||d}||jjz }|jD]F}|jD]5}|xj|z c_ |j|jz|_7H| r t!| |j|}  |j} t't)| |j*}|S#t"$rt%| |j|} Y^wxYw)a? Transcribe an audio file, with optional chunking for long files. Args: path (Path | str): Path to the audio file to be transcribed. dtype (mx.Dtype, optional): Data type for processing the audio. Defaults to mx.bfloat16. chunk_duration (float, optional): If provided, splits audio into chunks of this length (in seconds) for processing. When None, processes the entire file at once. Defaults to None. overlap_duration (float, optional): Overlap between consecutive chunks in seconds. Only used when chunk_duration is specified. Defaults to 15.0. chunk_callback (Callable, optional): A function to call when each chunk is processed. The callback is called with (current_position, total_position) arguments to track progress. Defaults to None. Returns: AlignedResult: Transcription result with aligned tokens and sentences. rgr)ro)rrr\rcrrllenr,rangeminrd sentencestokensstartdurationendr RuntimeErrorrrrrS)r^rqrmrhrnrorp audio_path audio_datariaudio_length_seconds chunk_samplesoverlap_samples all_tokensrxrz chunk_audio chunk_mel chunk_result chunk_offsetrStokenresults r0 transcribezBaseParakeet.transcribesM>$Z  D,D,D,P,PRWX  !Z)A)ABC==o=FqI I":1I1I1U1UU > 1Z)A)ABC==o=FqI INT-E-E-Q-QQR .1I1I1U1UUV 1c*o}/NOEem+S_=C)sC O4U{T55@@@$U3/K";0H0HII==O=TUVWL 4#;#;#G#GGL(22%__EKK</K % enn