o 㥵i@sddlZddlZddlmZddlmZddlZddlZddl m Z ddl m Z ddl mZmZe edd Zd e d dfd d Zded efddZdeded efddZdefddZdS)N) find_spec)Callable DictConfig) RankedLogger) enforce_tagsprint_config_treeT)rank_zero_onlycfgreturncCs|ds tddS|jdrtdtd|jdr-tdt|d d |jd rAtd t|d d d dSdS)zApplies optional utilities before the task is started. Utilities: - Ignoring python warnings - Setting tags from command line - Rich config printing extrasz*Extras config not found! Nignore_warningszignorerz.Enforcing tags! T) save_to_file print_configz>Printing config tree with Rich! )resolver) getlogwarningr infowarningsfilterwarningsrr r rK/home/ubuntu/.local/lib/python3.10/site-packages/fish_speech/utils/utils.pyr s         r task_funccsdtffdd }|S)aOOptional decorator that controls the failure behavior when executing the task function. This wrapper can be used to: - make sure loggers are closed even if the task function raises an exception (prevents multirun failure) - save the exception to a `.log` file - mark the run as failed with a dedicated file in the `logs/` folder (so we can find and rerun it later) - etc. (adjust depending on your needs) Example: ``` @utils.task_wrapper def train(cfg: DictConfig) -> Tuple[dict, dict]: ... return metric_dict, object_dict ``` r c sz@z |d\}}Wnty}ztd|d}~wwWtd|jjtdr=ddl}|jr=td| ||fStd|jjtdr`ddl}|jratd| www)Nrz Output dir: wandbrzClosing wandb!) Exceptionr exceptionrpathsrun_dirrrrunfinish)r metric_dict object_dictexrrrrwrapBs.    ztask_wrapper..wrapr)rr)rr(r task_wrapper.sr*r% metric_namecCsR|s tddS||vrtd|d||}td|d|d|S)z?Safely retrieves value of the metric logged in LightningModule.z7Metric name is None! Skipping metric value retrieval...Nz%Metric value not found! Make sure metric name logged in LightningModule is correct! Make sure `optimized_metric` name in `hparams_search` config is correct!zRetrieved metric value! <=>)rrritem)r%r+ metric_valuerrrget_metric_valueds   r0seedcCs|dkr| }|dkr d}t|tj|t|tjr.tj|tj|tjj r@dtjj _ dtjj _ dSdS)NrlTF) randomr1nptorch manual_seedcuda is_availablemanual_seed_allbackendscudnn deterministic benchmark)r1rrrset_seedxs        r=)r2rimportlib.utilrtypingrnumpyr3r4 omegaconfrloggerr rich_utilsrr __name__rr r*dictstrfloatr0intr=rrrrs     6