
    ^j9                        d Z ddlZddlmZ ddlmZ ddlZddlmZ ddlm	Z
 ddlmZ dd	lmZmZmZ dd
lmZ ddlmZmZmZ ddlmZmZ ddlmZ ddlmZmZmZm Z m!Z! ddl"m#Z#m$Z$ ddl%m&Z& ddl'm(Z( ddl)m*Z* ddl+m,Z,m-Z- ddl.m/Z/m0Z0m1Z1m2Z2 ddl3m4Z4m5Z5m6Z6  e!jn                  e8      Z9 ed      e G d de                    Z: G d dejv                        Z< G d dejv                        Z= G d  d!e*      Z> G d" d#e,      Z? G d$ d%ejv                        Z@ G d& d'e      ZAe G d( d)e             ZB ed*       G d+ d,eB             ZCe G d- d.e             ZDe G d/ d0eD             ZE ed1       G d2 d3eBe             ZF G d4 d5ejv                        ZG G d6 d7ejv                        ZHe G d8 d9e             ZI ed:       G d; d<eBe5             ZJ G d= d>eH      ZK ed?       G d@ dAe6eJ             ZLg dBZMy)CzPyTorch Parakeet model.    N)Callable)	dataclass)nn   )initialization)ACT2FN)CompileConfigGenerationMixinGenerationMode)GradientCheckpointingLayer)BaseModelOutputBaseModelOutputWithPoolingCausalLMOutput)ALL_ATTENTION_FUNCTIONSPreTrainedModel)Unpack)ModelOutputTransformersKwargsauto_docstringcan_return_tuplelogging)maybe_autocastmerge_with_config_defaults)capture_outputs   )	AutoModel)%FastSpeech2ConformerConvolutionModule)LlamaAttentioneager_attention_forward   )ParakeetCTCConfigParakeetEncoderConfigParakeetRNNTConfigParakeetTDTConfig)ParakeetRNNTDecoderCacheParakeetRNNTGenerationMixinParakeetTDTGenerationMixinz
    Extends [~modeling_outputs.BaseModelOutputWithPooling] to include the output attention mask since sequence length
    is not preserved in the model's forward.
    )custom_introc                   :    e Zd ZU dZdZej                  dz  ed<   y)ParakeetEncoderModelOutputa  
    attention_mask (`torch.Tensor` of shape `(batch_size, sequence_length)`, *optional*):
        Mask to avoid performing attention on padding token indices after sequence compression. Returned because the
        sequence length may differ from the input sequence length. Mask values selected in `[0, 1]`:

        - 1 for tokens that are **not masked**,
        - 0 for tokens that are **masked**.
    Nattention_mask)__name__
__module____qualname____doc__r+   torchTensor__annotations__     x/var/www/ramen.bs-engineer-server.com/venv/lib/python3.12/site-packages/transformers/models/parakeet/modular_parakeet.pyr*   r*   5   s     +/NELL4'.r4   r*   c                        e Zd ZU ej                  ed<   d	def fdZe	 	 d
dedz  dej                  fd       Z	 ej                         dej                  fd       Z xZS )$ParakeetEncoderRelPositionalEncodinginv_freqNconfigc                     t         |           |j                  | _        || _        | j	                  ||      }| j                  d|d       y )Ndevicer8   F)
persistent)super__init__max_position_embeddingsr9   .compute_default_relative_positional_parametersregister_buffer)selfr9   r<   r8   	__class__s       r5   r?   z-ParakeetEncoderRelPositionalEncoding.__init__L   sN    '-'E'E$FFvV\F]ZeDr4   returnc                     d}d|t        j                  d| j                  dt         j                        j	                  |t         j
                        | j                  z  z  z  }|S )Ng     @      ?r   r   dtype)r<   rI   )r0   arangehidden_sizeint64tofloat)r9   r<   baser8   s       r5   rA   zSParakeetEncoderRelPositionalEncoding.compute_default_relative_positional_parametersS   sd    
 Q 2 2AU[[ILLTZbgbmbmLn$$%
 r4   hidden_statesc                    |j                   d   }t        j                  |dz
  | d|j                        }| j                  d d d d f   j                         j                  |j                   d   dd      j                  |j                        }|d d d d f   j                         }t        |j                  j                  t              r/|j                  j                  dk7  r|j                  j                  nd}t        |d      5  |j                         |j                         z  j                  dd	      }|j                         }|j                         }	t        j                  ||	gd
      }
 |
j                   g |
j                   d d d }
d d d        
j                  |j"                        S # 1 sw Y   %xY w)Nr    r;   r   mpscpuF)device_typeenabledr   dimrH   )shaper0   rJ   r<   r8   rN   expandrM   
isinstancetypestrr   	transposesincosstackreshaperI   )rC   rP   
seq_lengthposition_idsinv_freq_expandedposition_ids_expandedrU   freqsr`   ra   	pos_embeds              r5   forwardz,ParakeetEncoderRelPositionalEncoding.forwardb   s   "((+
||JNZKML`L`aMM$4-(..0778K8KA8NPRTUVYYZgZnZno 	 !-T4] ; A A C -..33S9m>R>R>W>W[`>`   %% 	
 UC 	E&,,.1F1L1L1NNYYZ[]^_E))+C))+CS#JB7I)	))D9??3B+?DDI	E ||-"5"5|66	E 	Es   
BF::GNNN)r,   r-   r.   r0   r1   r2   r"   r?   staticmethodrA   no_gradrj   __classcell__rD   s   @r5   r7   r7   I   sx    llE4 E /3%, 
  U]]_7U\\ 7 7r4   r7   c                   *     e Zd Zdef fdZd Z xZS )ParakeetEncoderFeedForwardr9   c                 `   t         |           t        j                  |j                  |j
                  |j                        | _        t        |j                     | _
        t        j                  |j
                  |j                  |j                        | _        |j                  | _        y )Nbias)r>   r?   r   LinearrK   intermediate_sizeattention_biaslinear1r   
hidden_act
activationlinear2activation_dropoutrC   r9   rD   s     r5   r?   z#ParakeetEncoderFeedForward.__init__|   s|    yy!3!3V5M5MTZTiTij !2!23yy!9!96;M;MTZTiTij"(";";r4   c                     | j                  | j                  |            }t        j                  j	                  || j
                  | j                        }| j                  |      }|S )Nptraining)r{   ry   r   
functionaldropoutr}   r   r|   )rC   rP   s     r5   rj   z"ParakeetEncoderFeedForward.forward   sU    ](CD--mt?V?Vaeanan-o]3r4   )r,   r-   r.   r"   r?   rj   ro   rp   s   @r5   rr   rr   {   s    <4 <r4   rr   c                   &     e Zd Zddef fdZ xZS ) ParakeetEncoderConvolutionModuler9   c                 &    t         |   ||       y rk   )r>   r?   )rC   r9   module_configrD   s      r5   r?   z)ParakeetEncoderConvolutionModule.__init__   s    /r4   rk   )r,   r-   r.   r"   r?   ro   rp   s   @r5   r   r      s    04 0 0r4   r   c                        e Zd ZdZdedef fdZ	 ddej                  dej                  dz  dej                  dz  d	e	e
   d
eej                  ej                  f   f
dZd Z xZS )ParakeetEncoderAttentionztMulti-head attention with relative positional encoding. See section 3.3 of https://huggingface.co/papers/1901.02860.r9   	layer_idxc                    t         |   ||       d| _        t        j                  |j
                  |j                  | j                  z  d      | _        t        j                  t        j                  |j                  | j                              | _        t        j                  t        j                  |j                  | j                              | _        y )N)r   Frt   )r>   r?   	is_causalr   rv   rK   num_attention_headshead_dimrelative_k_proj	Parameterr0   zerosbias_ubias_vrC   r9   r   rD   s      r5   r?   z!ParakeetEncoderAttention.__init__   s    95!yy););V=W=WZ^ZgZg=gnstll5;;v/I/I4==#YZll5;;v/I/I4==#YZr4   NrP   position_embeddingsr+   kwargsrE   c           
         |j                   d d }|\  }}||d| j                  f}| j                  |      j                  |      j	                  dd      }	| j                  |      j                  |      j	                  dd      }
| j                  |      j                  |      j	                  dd      }t        j                  | j                  j                  t              }|	| j                  j                  d| j                  j                  d| j                        z   }|	| j                  j                  d| j                  j                  d| j                        z   }| j                  |      }|j                  |d| j                  j                  | j                        }||j!                  dddd      z  }| j#                  |      }|dd |f   }|| j$                  z  }|)|j'                  |j)                         t+        d            } || f||
||| j,                  sdn| j.                  | j$                  d	|\  }} |j0                  g |d j3                         }| j5                  |      }||fS )
NrR   r    r   r   r   .z-inf        )querykeyvaluer+   r   scaling)rZ   r   q_projviewr_   k_projv_projr   get_interfacer9   _attn_implementationr   r   r   r   r   permute
_rel_shiftr   masked_fill_logical_notrN   r   attention_dropoutrc   
contiguouso_proj)rC   rP   r   r+   r   input_shape
batch_sizerd   hidden_shapequery_states
key_statesvalue_statesattention_interfacequery_states_with_bias_uquery_states_with_bias_vrelative_key_states	matrix_bdattn_outputattn_weightss                      r5   rj   z ParakeetEncoderAttention.forward   sj    $))#2.!,
J"JDMMB{{=166|DNNqRST[[/44\BLLQPQR
{{=166|DNNqRST(?(M(MKK,,.E)
 $0$++2B2Bt{{..4==3
 $
  $0$++2B2Bt{{..4==3
 $
  #223FG166z2t{{GfGfhlhuhuv -/B/J/J1aQRTU/VV	OOI.	c;J;./	,	% "..~/I/I/KUSY][I %8	%
*$#}}C$2H2HLL	%
 	%
!\ *k));;;;FFHkk+.L((r4   c                     |j                   \  }}}}t        j                  j                  |d      }|j	                  ||d|      }|ddddddf   j	                  ||||      }|S )ztRelative position shift for Shaw et al. style attention. See appendix B of https://huggingface.co/papers/1901.02860.)r    r   )padrR   Nr    )rZ   r   r   r   r   )rC   attention_scoresr   	num_headsquery_lengthposition_lengths         r5   r   z#ParakeetEncoderAttention._rel_shift   st    ?O?U?U<
I|_==,,-=6,J+00YLY+Aq!"H5:::yR^`opr4   rk   )r,   r-   r.   r/   r"   intr?   r0   r1   r   r   tuplerj   r   ro   rp   s   @r5   r   r      s    ~[4 [ [ /3	7)||7) #\\D07) t+	7)
 +,7) 
u||U\\)	*7)r r4   r   c                        e Zd Zdef fdZdej                  dej                  fdZ	d	dej                  dej                  fdZ
 xZS )
 ParakeetEncoderSubsamplingConv2Dr9   c                    t         |           |j                  | _        |j                  | _        |j                  | _        | j                  dz
  dz  | _        t        t        j                  |j                              | _        t        j                         | _        | j                   j#                  t        j$                  d| j                  | j                  | j
                  | j                               | j                   j#                  t        j&                                t)        | j                  dz
        D ]  }| j                   j#                  t        j$                  | j                  | j                  | j                  | j
                  | j                  | j                               | j                   j#                  t        j$                  | j                  | j                  d             | j                   j#                  t        j&                                 |j*                  | j
                  | j                  z  z  }t        j,                  |j                  |z  |j.                  d      | _        y )Nr    r   )kernel_sizestridepadding)r   r   r   groupsr   Trt   )r>   r?   subsampling_conv_kernel_sizer   subsampling_conv_strider   subsampling_conv_channelschannelsr   r   mathlog2subsampling_factor
num_layersr   
ModuleListlayersappendConv2dReLUrangenum_mel_binsrv   rK   linear)rC   r9   i
out_lengthrD   s       r5   r?   z)ParakeetEncoderSubsamplingConv2D.__init__   s   !>>4488((1,2dii(A(ABC mmoIIaD4D4DT[[bfbnbno	
 	2779%t*+ 	*AKK		MMMM $ 0 0;; LL==	 KKryySTUVKKrwwy)	*" ((T[[$//-IJ
ii @ @: MvOaOahlmr4   input_lengths
conv_layerc                     t        |d      rR|j                  dk7  rC|j                  }|j                  d   }|j                  d   }||d   z   |d   z   |z
  |z  dz   }|S |S )Nr   )r    r    r   r    )hasattrr   r   r   )rC   r   r   r   r   r   output_lengthss          r5   _get_output_lengthz3ParakeetEncoderSubsamplingConv2D._get_output_length  sx    :x(Z->->&-H ((G$003K&&q)F+gaj871:ESX^^abbN!!r4   input_featuresr+   c                    |j                  d      }||j                  d      nd }| j                  D ]  } ||      }t        |t        j
                        s&|)| j                  ||      }|j                  d   }t        j                  ||j                        |d d d f   k  }||d d d d d d f   z  } |j                  dd      j                  |j                  d   |j                  d   d      }| j                  |      }|S )Nr    rR   r   r;   r   )	unsqueezesumr   r\   r   r   r   rZ   r0   rJ   r<   r_   rc   r   )rC   r   r+   rP   current_lengthslayercurrent_seq_lengthchannel_masks           r5   rj   z(ParakeetEncoderSubsamplingConv2D.forward  s   &0034B4N.,,R0TX[[ 
	@E!-0M %+0J"&"9"9/5"Q%2%8%8%;"LL!3N<Q<QRUdefhlelUmm  aq$.>!??
	@ &//15==m>Q>QRS>TVcViVijkVlnpqM2r4   rk   )r,   r-   r.   r"   r?   r0   r1   r   r   r   rj   ro   rp   s   @r5   r   r      sI    !n4 !nF	 	")) 	ell ELL r4   r   c                        e Zd Zddededz  f fdZ	 	 ddej                  dej                  dz  dej                  dz  dee	   d	ej                  f
d
Z
 xZS )ParakeetEncoderBlockNr9   r   c                    t         |           d| _        t        |      | _        t        ||      | _        t        |      | _        t        |      | _	        t        j                  |j                        | _        t        j                  |j                        | _        t        j                  |j                        | _        t        j                  |j                        | _        t        j                  |j                        | _        y )NF)r>   r?   gradient_checkpointingrr   feed_forward1r   	self_attnr   convfeed_forward2r   	LayerNormrK   norm_feed_forward1norm_self_att	norm_convnorm_feed_forward2norm_outr   s      r5   r?   zParakeetEncoderBlock.__init__$  s    &+#7?1&)D4V<	7?"$,,v/A/A"B\\&*<*<=f&8&89"$,,v/A/A"BV%7%78r4   rP   r+   r   r   rE   c                 x   |}| j                  | j                  |            }|d|z  z   }| j                  |      } | j                  d|||d|\  }}||z   }| j	                  | j                  |      |      }	||	z   }| j                  | j                  |            }
|d|
z  z   }| j                  |      }|S )Ng      ?)rP   r+   r   )r+   r3   )	r   r   r   r   r   r   r   r   r   )rC   rP   r+   r   r   residualnormalized_hidden_statesr   _conv_output
ff2_outputs              r5   rj   zParakeetEncoderBlock.forward3  s     !**4+B+B=+QR 3#66#'#5#5m#D ' 
2) 3
 	
Q &3ii} =ni]%3''(?(?(NO
%j(88m4r4   rk   rl   )r,   r-   r.   r"   r   r?   r0   r1   r   r   rj   ro   rp   s   @r5   r   r   #  sx    94 9t 9$ /337	|| t+ #\\D0	
 +, 
r4   r   c                        e Zd ZU eed<   dZdZdZdZdgZ	dZ
dZdZdZdZdZeedZ ej(                          fd	       Zd
ej,                  fdZddej,                  dedz  fdZ xZS )ParakeetPreTrainedModelr9   modelr   audioTr   F)rP   
attentionsc                    t         |   |       t        | j                  dd      }t	        |t
              rEt        j                  |j                  d|       t        j                  |j                  d|       y t	        |t              r<|j                  |j                        }t        j                  |j                  |       y y )Ninitializer_rangeg{Gz?r   )meanstd)r>   _init_weightsgetattrr9   r\   r   initnormal_r   r   r7   rA   copy_r8   )rC   moduler  buffer_valuerD   s       r5   r  z%ParakeetPreTrainedModel._init_weightsh  s    f%dkk#6=f67LLSc:LLSc: DE!PPQWQ^Q^_LJJv5 Fr4   r   c                    t        | j                  d| j                        }|j                  }|j                  }t	        t        j                  |j                              }|dz
  dz  dz  }||z
  }|}t        |      D ]Q  }	t        j                  |j                  t        j                        |z   |      dz   }t        j                  |      }S |j                  t        j                        S )Nencoder_configr    r   rH   rG   )r  r9   r   r   r   r   r   r   r   r0   divrM   rN   floor)
rC   r   r  r   r   r   all_paddingsadd_padlengthsr   s
             r5   _get_subsampling_output_lengthz6ParakeetPreTrainedModel._get_subsampling_output_lengtht  s     .>L$AA77>#D#DEF
#aA-1,z" 	+Aii


 = GPSVVGkk'*G	+ zz		z**r4   Nr+   target_lengthc                     | j                  |j                  d            }||n|j                         }t        j                  ||j
                        |dddf   k  }|S )z
        Convert the input attention mask to its subsampled form. `target_length` sets the desired output length, useful
        when the attention mask length differs from `sum(-1).max()` (i.e., when the longest sequence in the batch is padded)
        rR   Nr;   )r  r   maxr0   rJ   r<   )rC   r+   r  r   
max_lengths        r5   _get_output_attention_maskz2ParakeetPreTrainedModel._get_output_attention_mask  sc    
 <<^=O=OPR=ST&3&?]^EWEWEY
j9N9NOR`abdhahRiir4   rk   )r,   r-   r.   r!   r2   base_model_prefixmain_input_nameinput_modalitiessupports_gradient_checkpointing_no_split_modules_supports_flat_attention_mask_supports_sdpa_supports_flex_attn_supports_flash_attn_can_compile_fullgraph_supports_attention_backendr   r   _can_record_outputsr0   rn   r  r1   r  r   r  ro   rp   s   @r5   r   r   R  s    &O&*#/0$(!N !!"&-.
 U]]_	6 	6+ELL +"	 	VY\`V` 	r4   r   z{
    The Parakeet Encoder model, based on the [Fast Conformer architecture](https://huggingface.co/papers/2305.05084).
    c                        e Zd ZU eed<   dZdef fdZeee	e
	 	 ddej                  dej                  dz  dedee   d	ef
d
                            Z xZS )ParakeetEncoderr9   encoderc           	         t         |   |       || _        d| _        |j                  | _        |j
                  | _        |j                  | _        |j                  rt        j                  |j                        nd| _        t        |      | _        t        |      | _        t!        j"                  t%        |j&                        D cg c]  }t)        ||       c}      | _        | j-                          y c c}w )NFrG   )r>   r?   r9   r   r   dropout_positions	layerdropscale_inputr   sqrtrK   input_scaler   subsamplingr7   encode_positionsr   r   r   num_hidden_layersr   r   	post_initr   s      r5   r?   zParakeetEncoder.__init__  s     &+#~~!'!9!9))<B<N<N499V%7%78TW;FC DV LmmFKFLdLdFef!&)4f
 	 gs   
C:Nr   r+   output_attention_maskr   rE   c                 $   | j                  ||      }|| j                  z  }| j                  |      }t        j                  j                  || j
                  | j                        }t        j                  j                  || j                  | j                        }d}|u| j                  ||j                  d         }|j                  d      j                  d|j                  d   d      }||j                  dd      z  }|j                  d      }| j                  D ]E  }d}	| j                  r&t        j                  g       }
|
| j                   k  rd}	|	r: ||f||d	|}G t#        |||r|j%                         
      S d
      S )a  
        output_attention_mask (`bool`, *optional*, defaults to `True`):
            Whether to return the output attention mask. Only effective when `attention_mask` is provided.

        Example:

        ```python
        >>> from transformers import AutoProcessor, ParakeetEncoder
        >>> from datasets import load_dataset, Audio

        >>> model_id = "nvidia/parakeet-ctc-1.1b"
        >>> processor = AutoProcessor.from_pretrained(model_id)
        >>> encoder = ParakeetEncoder.from_pretrained(model_id)

        >>> ds = load_dataset("hf-internal-testing/librispeech_asr_dummy", "clean", split="validation")
        >>> ds = ds.cast_column("audio", Audio(sampling_rate=processor.feature_extractor.sampling_rate))

        >>> inputs = processor(ds[0]["audio"]["array"])
        >>> encoder_outputs = encoder(**inputs)

        >>> print(encoder_outputs.last_hidden_state.shape)
        ```
        r   Nr    r  rR   r   FT)r+   r   )last_hidden_stater+   )r.  r-  r/  r   r   r   r   r)  r  rZ   r   r[   r_   r   r0   randr*  r*   r   )rC   r   r+   r2  r   rP   r   output_maskencoder_layerto_dropdropout_probabilitys              r5   rj   zParakeetEncoder.forward  s   F ((H%(8(88"33MB--mt||VZVcVc-d mm334#9#9DMM 4 
 %99.XeXkXklmXn9oK(2215<<RATATUVAWY[\N+n.F.Fq!.LLN+55a8N![[ 	MG}}&+jjn#&7"G -!!#1(;! 	!	  *+0>0JOd;??,
 	
jn
 	
r4   )NT)r,   r-   r.   r"   r2   r  r?   r   r   r   r   r0   r1   boolr   r   r   rj   ro   rp   s   @r5   r&  r&    s     "!!4 &  /3&*	B
B
 t+B
  $	B

 +,B
 
B
     B
r4   r&  c                       e Zd ZU dZej
                  ed<   dZeej                     dz  ed<   dZ
eeej                        dz  ed<   dZeeej                        dz  ed<   y)ParakeetCTCGenerateOutputaz  
    Outputs of Parakeet CTC model generation.

    Args:
        sequences (`torch.LongTensor` of shape `(batch_size, sequence_length)`):
            The generated sequences. The second dimension (sequence_length) is either equal to `max_length` or shorter
            if all batches finished early due to the `eos_token_id`.
        logits (`tuple(torch.FloatTensor)` *optional*, returned when `output_logits=True`):
            Unprocessed prediction scores of the language modeling head (scores for each vocabulary token before SoftMax)
            at each generation step. Tuple of `torch.FloatTensor` with up to `max_new_tokens` elements (one element for
            each generated token), with each tensor of shape `(batch_size, config.vocab_size)`.
        attentions (`tuple(tuple(torch.FloatTensor))`, *optional*, returned when `output_attentions=True`):
            Tuple (one element for each generated token) of tuples (one element for each layer of the decoder) of
            `torch.FloatTensor` of shape `(batch_size, num_heads, generated_length, sequence_length)`.
        hidden_states (`tuple(tuple(torch.FloatTensor))`, *optional*, returned when `output_hidden_states=True`):
            Tuple (one element for each generated token) of tuples (one element for each layer of the decoder) of
            `torch.FloatTensor` of shape `(batch_size, generated_length, hidden_size)`.
    	sequencesNlogitsr   rP   )r,   r-   r.   r/   r0   
LongTensorr2   r?  r   FloatTensorr   rP   r3   r4   r5   r=  r=    sm    & .2FE%##$t+29=JeE--./$6=<@M5u0012T9@r4   r=  c                   "     e Zd ZdZ fdZ xZS )ParakeetGenerateOutputz`
    Deprecated alias for ParakeetCTCGenerateOutput. Use ParakeetCTCGenerateOutput instead.
    c                 N    t        |   |i | t        j                  d       y )Nz`ParakeetGenerateOutput` is deprecated and removed starting from version 5.11.0; please use `ParakeetCTCGenerateOutput` instead.)r>   r?   loggerwarning_once)rC   argsr   rD   s      r5   r?   zParakeetGenerateOutput.__init__  s)    $)&) O	
r4   )r,   r-   r.   r/   r?   ro   rp   s   @r5   rC  rC    s    
 
r4   rC  zS
    Parakeet Encoder with a Connectionist Temporal Classification (CTC) head.
    c                   X    e Zd ZU eed<   def fdZee	 	 ddej                  dej                  dz  dej                  dz  de
e   def
d	              Z ej                         	 	 	 ddej                  dej                  dz  d
ededz  de
e   deej$                  z  fd       Z xZS )ParakeetForCTCr9   c                    t         |   |       t        j                  |j                        | _        t        j                  |j                  j                  |j                  d      | _
        | j                          y )Nr    r   )r>   r?   r   from_configr  r'  r   Conv1drK   
vocab_sizectc_headr1  r~   s     r5   r?   zParakeetForCTC.__init__&  sY      ,,V-B-BC		&"7"7"C"CVEVEVdefr4   Nr   r+   labelsr   rE   c           
         ||j                  dd        | j                  d||d|}|j                  }| j                  |j	                  dd            j	                  dd      }d}|+|j
                  j                  d      }	|| j                  j                  k7  }
|
j                  d      }|j                  |
      }t        j                  j                  |dt        j                        j	                  d	d      }t        j                  j                   j#                  d
      5  t        j                  j%                  |||	|| j                  j                  | j                  j&                  | j                  j(                        }ddd       t+        |||j,                  |j.                        S # 1 sw Y   ,xY w)a  
        Example:

        ```python
        >>> from transformers import AutoProcessor, ParakeetForCTC
        >>> from datasets import load_dataset, Audio

        >>> model_id = "nvidia/parakeet-ctc-1.1b"
        >>> processor = AutoProcessor.from_pretrained(model_id)
        >>> model = ParakeetForCTC.from_pretrained(model_id)

        >>> ds = load_dataset("hf-internal-testing/librispeech_asr_dummy", "clean", split="validation")
        >>> ds = ds.cast_column("audio", Audio(sampling_rate=processor.feature_extractor.sampling_rate))

        >>> inputs = processor(ds[0]["audio"]["array"], text=ds[0]["text"])
        >>> outputs = model(**inputs)

        >>> print(outputs.loss)
        ```Nr2  Tr   r+   r    r   rR   )rX   rI   r   F)rV   )blank	reductionzero_infinity)lossr?  rP   r   r3   )
setdefaultr'  r5  rN  r_   r+   r   r9   pad_token_idmasked_selectr   r   log_softmaxr0   float32backendscudnnflagsctc_lossctc_loss_reductionctc_zero_infinityr   rP   r   )rC   r   r+   rO  r   encoder_outputsrP   r?  rU  encoder_lengthslabels_masktarget_lengthsflattened_targets	log_probss                 r5   rj   zParakeetForCTC.forward.  s   : 5t<&$,, 
))
 
 (99}66q!<=GG1M-<<@@DO !DKK$<$<<K(__R0N & 4 4[ A 11&b1V``abdefI%%++E+: 	}}--%#"++22"kk<<"&++"?"? . 	 )77&11	
 	
	 	s   ,A#F::Greturn_dict_in_generatecompile_configc                 r   || j                  |      n| j                  }d|d<    |d	||d|}|j                  j                  d      }|:| j	                  ||j
                  d         }| j                  j                  || <   |r-t        ||j                  |j                  |j                        S |S )
a  
        compile_config ([`~generation.CompileConfig`], *optional*):
            If provided, `torch.compile` will be applied to the forward calls in the decoding loop.

        Example:

        ```python
        >>> from transformers import AutoProcessor, ParakeetForCTC
        >>> from datasets import load_dataset, Audio

        >>> model_id = "nvidia/parakeet-ctc-1.1b"
        >>> processor = AutoProcessor.from_pretrained(model_id)
        >>> model = ParakeetForCTC.from_pretrained(model_id)

        >>> ds = load_dataset("hf-internal-testing/librispeech_asr_dummy", "clean", split="validation")
        >>> ds = ds.cast_column("audio", Audio(sampling_rate=processor.feature_extractor.sampling_rate))

        >>> inputs = processor(ds[0]["audio"]["array"], text=ds[0]["text"])
        >>> predicted_ids = model.generate(**inputs)
        >>> transcription = processor.batch_decode(predicted_ids, skip_special_tokens=True)

        >>> print(transcription)
        ```
        Treturn_dictrQ  rR   rW   r    r4  )r>  r?  r   rP   r3   )get_compiled_call__call__r?  argmaxr  rZ   r9   rW  r=  r   rP   )	rC   r   r+   rg  rh  r   model_forwardoutputsr>  s	            r5   generatezParakeetForCTC.generatet  s    B CQB\..~>bfbobo $}"/ #
))#
 #
 NN))b)1	 %!<<^[d[j[jkl[m<nN)-)A)AI~o&",#~~"--%33	  r4   rl   )NFN)r,   r-   r.   r!   r2   r?   r   r   r0   r1   r   r   r   rj   rn   r;  r	   r=  r@  rp  ro   rp   s   @r5   rI  rI    s    0   /3&*	B
B
 t+B
 t#	B

 +,B
 
B
  B
H U]]_ /3(-/399 t+9 "&	9
 &,9 +,9 
#U%5%5	59 9r4   rI  c                   n     e Zd ZdZdef fdZ	 d	dej                  dedz  dej                  fdZ
 xZS )
ParakeetRNNTDecoderz'LSTM-based prediction network For RNN-Tr9   c                 x   t         |           |j                  | _        t        j                  |j
                  |j                        | _        t        j                  |j                  |j                  |j                  d      | _
        t        j                  |j                  |j                        | _        y )NT)
input_sizerK   r   batch_first)r>   r?   blank_token_idr   	EmbeddingrM  decoder_hidden_size	embeddingLSTMnum_decoder_layerslstmrv   decoder_projectorr~   s     r5   r?   zParakeetRNNTDecoder.__init__  s    $33f&7&79S9STGG112200	
	 "$6+E+EvGaGa!br4   N	input_idscacherE   c                    |>|d d df   | j                   k(  }|j                  r|j                         r|j                  S | j	                  |      }|8|j                  }|s|j                  |       |j                  |j                  f}nd }| j                  ||      \  }\  }}	| j                  |      }
|(r nd }|j                  |
||	|       |j                  S |
S )NrR   )mask)rv  is_initializedallr  ry  lazy_initializationhidden_state
cell_stater|  r}  update)rC   r~  r  
blank_mask
embeddingswas_initializedhidden_cell_stateslstm_outputr  r  decoder_outputr  s               r5   rj   zParakeetRNNTDecoder.forward  s    
 "1b5)T-@-@@J##
(8{{"^^I.
 #22O"))*5"'"4"4e6F6F!G!%26))JHZ2[//lJ//<"1J;tDLLzLM;;r4   rk   )r,   r-   r.   r/   r#   r?   r0   r@  r%   r1   rj   ro   rp   s   @r5   rr  rr    sJ    1
c1 
c 26## ($. 
	r4   rr  c                        e Zd ZdZdef fdZdej                  dej                  deej                  ej                  f   fdZ	 xZ
S )ParakeetRNNTJointNetworkzPJoint network that combines encoder and decoder outputs to predict token logits.r9   c                     t         |           t        |j                     | _        t        j                  |j                  |j                        | _	        |j                  | _        y rk   )
r>   r?   r   rz   r{   r   rv   rx  rM  headr~   s     r5   r?   z!ParakeetRNNTJointNetwork.__init__  sK     !2!23IIf88&:K:KL	 ++r4   decoder_hidden_statesencoder_hidden_statesrE   c                 L    | j                  ||z         }| j                  |      S rk   )r{   r  )rC   r  r  joint_outputs       r5   rj   z ParakeetRNNTJointNetwork.forward  s(    
 '<?T'TUyy&&r4   )r,   r-   r.   r/   r#   r?   r0   r1   r   rj   ro   rp   s   @r5   r  r    sN    Z,1 ,'$||'  %||' 
u||U\\)	*	'r4   r  c                   v    e Zd ZU dZdZej                  dz  ed<   dZej                  dz  ed<   dZ	e
dz  ed<   y)ParakeetRNNTOutputa  
    Output of the Parakeet RNN-T forward pass.

    Args:
        loss (`torch.FloatTensor`, *optional*):
            RNN-T loss, returned when `labels` are provided.
        logits (`torch.FloatTensor`):
            Joint token logits. Shape is `(batch, T, U+1, vocab)` for training
            or `(batch, 1, 1, vocab)` for single-step inference.
        decoder_cache (`ParakeetRNNTDecoderCache`, *optional*):
            Decoder LSTM cache containing hidden state, cell state, and last output.
    NrU  r?  decoder_cache)r,   r-   r.   r/   rU  r0   rA  r2   r?  r  r%   r3   r4   r5   r  r    sC     &*D%

d
")'+FE$+59M+d29r4   r  z?
    Parakeet Encoder with an RNN-T (RNN Transducer) head.
    c                       e Zd ZU eed<   dgZej                  gZdef fdZ	e
	 ddej                  dej                  dz  dee   defd	       Zee
	 	 	 	 	 	 	 ddej                  dz  dej                  dz  d
ej$                  dz  dedz  dedz  deeej,                     z  dz  dej                  dz  dee   defd              Z xZS )ParakeetForRNNTr9   rr  c                 `   t         |   |       t        j                  |j                        | _        t        j                  |j                  j                  |j                        | _
        t        |      | _        t        |      | _        |j                  | _        | j!                          y rk   )r>   r?   r   rK  r  r'  r   rv   rK   rx  encoder_projectorrr  decoderr  jointmax_symbols_per_stepr1  r~   s     r5   r?   zParakeetForRNNT.__init__  s}      ,,V-B-BC!#6+@+@+L+LfNhNh!i*62-f5
$*$?$?!r4   Nr   r+   r   rE   c                 p     | j                   d||d|}| j                  |j                        |_        |S )NrQ  r3   )r'  r  r5  pooler_output)rC   r   r+   r   ra  s        r5   get_audio_featuresz"ParakeetForRNNT.get_audio_features  sJ     '$,, 
))
 

 )-(>(>?`?`(a%r4   decoder_input_idsr  use_decoder_cachera  rO  c           
         | | j                   d	||d|}|r|t        | j                        }| j                  ||      }	| j	                  |j
                  dddddddf   |	dddddddf         j                  d      }
d}||j                  j                  d      } | j                  d	|
dddt        |j                               f   |||| j                  j                  k7  j                  d      | j                  j                  d|}t        ||
|j                  |j
                  |j                  |j                   |      S )
a?  
        decoder_input_ids (`torch.LongTensor` of shape `(batch_size, 1)`, *optional*):
            Decoder input token ids for single-step inference.
        decoder_cache (`ParakeetRNNTDecoderCache`, *optional*):
            Decoder LSTM cache. When provided and initialized, the cached `decoder_output` is reused
            (e.g. during blank-skipping) instead of running the decoder. When `input_ids` is provided,
            the decoder runs and the cache is updated in-place.
        use_decoder_cache (`bool`, *optional*):
            Whether to use a decoder cache. When `True` and `decoder_cache` is `None`, a new cache
            is created automatically during the forward pass.
        encoder_outputs (`tuple(torch.FloatTensor)`, *optional*):
            Pre-computed encoder outputs (last_hidden_state, pooler_output, hidden_states, attentions, attention_mask).
            Can be a tuple or `ParakeetEncoderModelOutput`.

        Example:

        ```python
        >>> from transformers import AutoProcessor, ParakeetForRNNT
        >>> from datasets import load_dataset, Audio

        >>> model_id = "nvidia/parakeet-rnnt-0.6b"
        >>> processor = AutoProcessor.from_pretrained(model_id)
        >>> model = ParakeetForRNNT.from_pretrained(model_id)

        >>> ds = load_dataset("hf-internal-testing/librispeech_asr_dummy", "clean", split="validation")
        >>> ds = ds.cast_column("audio", Audio(sampling_rate=processor.feature_extractor.sampling_rate))

        >>> inputs = processor(ds[0]["audio"]["array"])
        >>> outputs = model(**inputs)
        ```
        NrQ  r  r  r  r   rR   )r?  rO  logit_lengthslabel_lengthsrv  rU  r?  r5  r  rP   r   r  r3   )r  r%   r9   r  r  r  squeezer+   r   loss_functionr   r  rv  r  r5  rP   r   )rC   r   r+   r  r  r  ra  rO  r   r  r?  rU  r  s                r5   rj   zParakeetForRNNT.forward*  sv   X "5d55 -- O !64T[[AM $->m T"1"?"?1dA"N"74A"F  
 '!* 	
 +::>>rBM%4%% a!;3}'8'8':#;!;;<+%)C)CCHHL#{{99 D "-??)77)77&11'
 	
r4   rk   NNNNNNN)r,   r-   r.   r#   r2   r  r   GREEDY_SEARCH_supported_generation_modesr?   r   r0   r1   r   r   r*   r  r   r@  r%   r;  r   rA  r  rj   ro   rp   s   @r5   r  r    sc    ./#1#?#?"@1   /3 t+ +,	
 
$   /3.2599=)-X\&*N
t+N
 t+N
 !++d2	N

 0$6N
  $;N
 4eE<M<M6NNQUUN
 t#N
 +,N
 
N
  N
r4   r  c                   (     e Zd ZdZdef fdZ xZS )ParakeetTDTJointNetworka
  Extends the RNN-T joint network with a duration head.

    The only difference from [`ParakeetRNNTJointNetwork`] is the output width of `head`: it grows from
    `vocab_size` to `vocab_size + len(durations)` so the network jointly predicts tokens and durations.
    r9   c                     t         |   |       t        j                  |j                  |j
                  t        |j                        z         | _        y rk   )	r>   r?   r   rv   rx  rM  len	durationsr  r~   s     r5   r?   z ParakeetTDTJointNetwork.__init__  s?     IIf88&:K:KcRXRbRbNc:cd	r4   )r,   r-   r.   r/   r$   r?   ro   rp   s   @r5   r  r  }  s    e0 e er4   r  zG
    Parakeet Encoder with a TDT (Token Duration Transducer) head.
    c                        e Zd ZU eed<   def fdZee	 	 	 	 	 	 	 ddej                  dz  dej                  dz  dej                  dz  dedz  dedz  d	eeej                     z  dz  d
ej                  dz  dee   defd              Z xZS )ParakeetForTDTr9   c                 d    t         |   |       t        |      | _        | j	                          y rk   )r>   r?   r  r  r1  r~   s     r5   r?   zParakeetForTDT.__init__  s&     ,V4
r4   Nr   r+   r  r  r  ra  rO  r   rE   c                    | | j                   d
||d|}|r|t        | j                        }| j                  ||      }	| j	                  |j
                  dddddddf   |	dddddddf         j                  d      }
d}| | j                  d
|
dd| j                  j                  f   |
d| j                  j                  df   ||j                  j                  d      || j                  j                  k7  j                  d      | j                  j                  | j                  j                  d|}t        ||
|j                  |j
                  |j                   |j"                  |	      S )a?  
        decoder_input_ids (`torch.LongTensor` of shape `(batch_size, 1)`, *optional*):
            Decoder input token ids for single-step inference.
        decoder_cache (`ParakeetRNNTDecoderCache`, *optional*):
            Decoder LSTM cache. When provided and initialized, the cached `decoder_output` is reused
            (e.g. during blank-skipping) instead of running the decoder. When `input_ids` is provided,
            the decoder runs and the cache is updated in-place.
        use_decoder_cache (`bool`, *optional*):
            Whether to use a decoder cache. When `True` and `decoder_cache` is `None`, a new cache
            is created automatically during the forward pass.
        encoder_outputs (`tuple(torch.FloatTensor)`, *optional*):
            Pre-computed encoder outputs (last_hidden_state, pooler_output, hidden_states, attentions, attention_mask).
            Can be a tuple or `ParakeetEncoderModelOutput`.

        Example:

        ```python
        >>> from transformers import AutoProcessor, ParakeetForTDT
        >>> from datasets import load_dataset, Audio

        >>> model_id = "nvidia/parakeet-tdt-0.6b-v3"
        >>> processor = AutoProcessor.from_pretrained(model_id)
        >>> model = ParakeetForTDT.from_pretrained(model_id)

        >>> ds = load_dataset("hf-internal-testing/librispeech_asr_dummy", "clean", split="validation")
        >>> ds = ds.cast_column("audio", Audio(sampling_rate=processor.feature_extractor.sampling_rate))

        >>> inputs = processor(ds[0]["audio"]["array"])
        >>> outputs = model(**inputs)
        ```
        NrQ  r  r  r   .rR   )token_logitsduration_logitsrO  r  r  rv  r  r  r3   )r  r%   r9   r  r  r  r  r  rM  r+   r   rW  rv  r  r  r5  rP   r   )rC   r   r+   r  r  r  ra  rO  r   r  r?  rU  s               r5   rj   zParakeetForTDT.forward  s   X "5d55 -- O !64T[[AM $->m T"1"?"?1dA"N"74A"F  
 '!* 	
 %4%% 	#C)A4;;+A+A)A$AB &sDKK,B,B,D'D E-<<@@D%)A)AAFFrJ#{{99++//	 	D "-??)77)77&11'
 	
r4   r  )r,   r-   r.   r$   r2   r?   r   r   r0   r1   r@  r%   r;  r*   r   rA  r   r   r  rj   ro   rp   s   @r5   r  r    s     0   /3.2599=)-X\&*O
t+O
 t+O
 !++d2	O

 0$6O
  $;O
 4eE<M<M6NNQUUO
 t#O
 +,O
 
O
  O
r4   r  )rI  r  r  r&  r   )Nr/   r   collections.abcr   dataclassesr   r0   r    r   r  activationsr   
generationr	   r
   r   modeling_layersr   modeling_outputsr   r   r   modeling_utilsr   r   processing_utilsr   utilsr   r   r   r   r   utils.genericr   r   utils.output_capturingr   autor   4fastspeech2_conformer.modeling_fastspeech2_conformerr   llama.modeling_llamar   r   configuration_parakeetr!   r"   r#   r$   generation_parakeetr%   r&   r'   
get_loggerr,   rE  r*   Moduler7   rr   r   r   r   r   r   r&  r=  rC  rI  rr  r  r  r  r  r  __all__r3   r4   r5   <module>r     s[     $ !   & ! H H 9 [ [ F &  H 5  h J s s  
		H	%  
/!; 
/ 
//7299 /7d 0'L 0
L ~ L ^Bryy BJ,5 ,^ ;o ; ;| 
]
- ]

]
@ A A A4 	
6 	
 	
 
K,o K
K\-")) -`'ryy '$ :3 : :& 
n
-/J n

n
b	e6 	e 
Z
/ Z

Z
z pr4   