o
    wi!                  (   @   s  d dl mZ d dlmZ d dlZd dl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mZmZ d d	lmZ d d
lmZ dZejjeddejej  fddZ!ejje
edddddddddddddddddddddddd dde
fdee" d e"d!e#d"e#d#eej$ d$ee# d%e#d&e%d'e#d(e#d)e#d*e"d+e#d,e&d-e#d.e#d/e#d0e#dej'f&d1d2Z(ejje	ed					3	d8dee" d e"d'e#d(e#d4ee" d5e%dej'fd6d7Z)dS )9    )OptionalN)finetunepretrain)MockDataModule)PEFT_STR2CLS)default_finetune_recipe)gemma2_modelgemma2_trainer)default_logdefault_resumetensorboard_logger),distributed_fused_adam_with_cosine_annealing)TimingCallback	gemma2_2bnamereturnc                   C   s
   t tdS )a[  
    Factory function to create a Gemma2 2B model configuration.

    Returns:
        run.Config[pl.LightningModule]: Configuration for the Gemma2 2B model.

    Examples:
        CLI usage:
            $ nemo llm pretrain model=gemma2 ...

        Python API usage:
            >>> model_config = model()
            >>> print(model_config)
    )version)r   NAME r   r   c/home/ubuntu/sommelier/.venv/lib/python3.10/site-packages/nemo/collections/llm/recipes/gemma2_2b.pymodel!   s   
r   )targetr   default      F   i{ z
bf16-mixedg      ?    
   i  i   giUMu>ga2U0*3?dirr   tensor_parallelismpipeline_parallelismpipeline_parallelism_typevirtual_pipeline_parallelismcontext_parallelismsequence_parallelism	num_nodesnum_gpus_per_node	max_steps	precisionaccumulate_grad_batchesgradient_clip_vallimit_test_batcheslimit_val_batcheslog_every_n_stepsval_check_intervalc                 C   s   t j|t tdi d|d|d|d|d|d|d|d|	d	|
d
|d|d|d|d|d|dt tgt jt|||dt| |t|ddt	||||||dt
 dS )a  
    Create a pre-training recipe for gemma2 2B model.

    This function sets up a complete configuration for pre-training, including
    model, trainer, data, logging, optimization, and resumption settings.

    Args:
        dir (Optional[str]): Directory for saving logs and checkpoints.
        name (str): Name of the pre-training run.
        tensor_parallelism (int): Degree of tensor model parallelism.
        pipeline_parallelism (int): Degree of pipeline model parallelism.
        pipeline_parallelism_type (Optional[torch.dtype]): Data type for pipeline parallelism.
        virtual_pipeline_parallelism (Optional[int]): Size of virtual pipeline parallelism.
        context_parallelism (int): Degree of context parallelism.
        sequence_parallelism (bool): Whether to use sequence parallelism.
        num_nodes (int): Number of compute nodes to use.
        num_gpus_per_node (int): Number of GPUs per node.
        max_steps (int): Maximum number of training steps.
        precision (str): Precision configuration, one of fp32, 16-mixed or bf16-mixed.
        accumulate_grad_batches (int): Number of steps per gradient accumulation.
        gradient_clip_val (float): Value for gradient clipping.
        limit_test_batches (int): Limit the number of test batches.
        limit_val_batches (int): Limit the number of validation batches.
        log_every_n_steps (int): Log every n steps.
        val_check_interval (int): Run validation every N steps.
        global_batch_size (int): Global batch size.
        micro_batch_size (int): Micro batch size.
        seq_length (int): Sequence length.
        warmup_steps (int): Number of warmup steps.
        constant_steps (int): Number of constant steps.
        min_lr (float): Minimum learning rate.
        max_lr (float): Maximum learning rate.
        fn (Callable): The pre-training function to use.

    Returns:
        run.Partial: Partial configuration for pre-training.

    Examples:
        CLI usage:
            $ nemo llm pretrain --factory gemma2_2b
            $ nemo llm pretrain --factory "gemma2_2b(num_nodes=1, name='my_gemma2_pretrain')"

        Python API usage:
            >>> recipe = pretrain_recipe(name="gemma2_pretrain", num_nodes=1)
            >>> print(recipe)
    r    r!   r"   r#   r$   r%   r&   r'   r(   r)   r*   r,   r-   r.   r/   	callbacks)
seq_lengthglobal_batch_sizemicro_batch_sizer   )r   r   r   )r)   warmup_stepsconstant_stepsmin_lrmax_lr	clip_grad)r   trainerdatalogoptimresumeNr   )runPartialr   r	   Configr   r   r
   r   r   r   )r   r   r    r!   r"   r#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r2   r3   r1   r4   r5   r6   r7   fnr   r   r   pretrain_recipe5   sj   P	
rB   lorapeft_schemepacked_sequencec                 C   s   t t d| ||||}ddi|j_|du s| dkr"d|jj_|S | dv r9t	t
|  |_d|jj_|S td	| )
a  
    Create a fine-tuning recipe for Gemma2 2B model.

    This function sets up a complete configuration for fine-tuning, including
    model, trainer, data, logging, optimization, and resumption settings.
    The recipe uses LoRA (Low-Rank Adaptation) for efficient fine-tuning, unless peft_scheme is set to None.

    Args:
        dir (Optional[str]): Directory for saving logs and checkpoints.
        name (str): Name of the fine-tuning run.
        num_nodes (int): Number of compute nodes to use.
        num_gpus_per_node (int): Number of GPUs per node.
        peft_scheme (Optional[str]): Name of the peft scheme to use for fine-tuning.
            Allowed values: 'lora'/'dora'/'none'/None.
        packed_sequence (Optional[bool]): Packing multiple training sequences into one long sequence for training
            efficiency. Default sequence length is 2048.

    Returns:
        run.Partial: Partial configuration for fine-tuning.

    Examples:
        CLI usage:
            $ nemo llm finetune --factory gemma2_2b

        Python API usage:
            >>> recipe = finetune_recipe(name="gemma2_2b_finetune", num_nodes=2)
            >>> print(recipe)

    Note:
        This recipe uses the SQuAD dataset for fine-tuning.
    zgoogle/gemma-2-2badd_bosTNnonegh㈵>)rC   dorag-C6?zUnrecognized peft scheme: )r   r   r:   dataset_kwargslowerr<   configlrr>   r@   r   peft
ValueError)r   r   r&   r'   rD   rE   reciper   r   r   finetune_recipe   s   (

rP   )Nr   r   r   rC   F)*typingr   lightning.pytorchpytorchplnemo_runr>   torchnemo.collections.llm.apir   r   "nemo.collections.llm.gpt.data.mockr   nemo.collections.llm.peftr   -nemo.collections.llm.recipes.finetune_defaultr   #nemo.collections.llm.recipes.gemma2r   r	   (nemo.collections.llm.recipes.log.defaultr
   r   r   'nemo.collections.llm.recipes.optim.adamr   nemo.utils.exp_managerr   r   clifactoryr@   LightningModuler   strintdtypeboolfloatr?   rB   rP   r   r   r   r   <module>   s   	
 w