o wi7@sddlZddlZddlmZmZmZmZddlmZ ddl m Z ddl m Z GdddZded ed dfd d Zeed ddd gZdS)N)AnyCallableListOptional)Callback) BaseCallback)OneLoggerNeMoCallbackc@seZdZUdZdZeded<edddZdddZ d e ddfd d Z d e d e ddfddZededfddZde defddZdddZdS) CallbackGroupaA singleton registry to host and fan-out lifecycle callbacks. Other code should call methods on this group (e.g., `on_model_init_start`). The group will iterate all registered callbacks and, if a callback implements the method, invoke it with the provided arguments. N _instancereturncCs|jdur t|_|jS)zzGet the singleton instance of CallbackGroup. Returns: CallbackGroup: The singleton instance. N)r r )clsr Z/home/ubuntu/sommelier/.venv/lib/python3.10/site-packages/nemo/lightning/callback_group.py get_instance"s zCallbackGroup.get_instancecCstg|_d|_dS)NF)r _callbacks_app_end_emittedselfr r r__init__-s  zCallbackGroup.__init__callbackcCs|j|dS)zrRegister a callback to the callback group. Args: callback: The callback to register. N)rappend)rrr r rregister2szCallbackGroup.register nemo_versiontrainerc Ksg}|jD]%}t|ts qt|dr%t|d}t|r%|d ||d|||qtt|dg}dd|D}||} | D].}z#t|dd} t| tsd|j j dt|j d |j j } t |d| Wq@t ynYq@w| |_dS) amUpdate configuration across all registered callbacks and attach them to trainer. Args: nemo_version: Version key (e.g., 'v1' or 'v2') for downstream config builders. trainer: Lightning Trainer to which callbacks should be attached if missing. **kwargs: Forwarded to each callback's update_config implementation. update_config)rr callbackscSsg|] }t|tr|qSr ) isinstance PTLCallback).0cbr r r Psz/CallbackGroup.update_config.. state_keyN. __qualname__r )rrrhasattrgetattrcallablerliststr __class__ __module____name__setattr Exceptionr) rrrkwargssanitized_group_callbacksrmethodexistingsanitized_trainer_callbacksrkeysafe_keyr r rr:s0          zCallbackGroup.update_configrcCs|jS)z~Get the list of registered callbacks. Returns: List[BaseCallback]: List of registered callbacks. )rrr r rrbszCallbackGroup.callbacks method_namecsfdd}|S)zDynamically create a dispatcher for unknown attributes. Any attribute access is treated as a lifecycle method name. When invoked, the dispatcher will call that method on each registered callback if it exists. cs:jD]}t|rt|}t|r||i|qdSN)rr$r%r&)argsr.rr0r5rr r dispatcherss   z-CallbackGroup.__getattr__..dispatcherr )rr5r9r r8r __getattr__kszCallbackGroup.__getattr__cOsJ|jrdSd|_|jD]}t|dr"t|d}t|r"||i|q dS)zEmit application-end callbacks exactly once per process. Invokes `on_app_end` on each registered callback, if present. Subsequent calls are no-ops. All positional and keyword arguments are forwarded. NT on_app_end)rrr$r%r&)rr7r.rr0r r rr;}s   zCallbackGroup.on_app_end)r r )r N)r+r*r#__doc__r r__annotations__ classmethodrrrrr(rrpropertyrrrr:r;r r r rr s   (r start_callback end_callbackr csNt|dsdS|jtddrdStfdd}d|_||_dS)aHook a class's __init__ to emit CallbackGroup start/end hooks. Args: cls (type): Class whose __init__ should be wrapped. start_callback (str): CallbackGroup method to call before __init__. end_callback (str): CallbackGroup method to call after __init__. rN_init_wrapped_for_callbacksFcs|t|ddr|g|Ri|St|ddt}t|r&t||g|Ri|}t|r.wrapped_initT)r$rr% functoolswrapsrB)r r@rArHr rFrhook_class_init_with_callbackss   rKcCs tSr6)r rr;r r r rs rL)atexitrItypingrrrrlightning.pytorch.callbacksrrnemo.lightning.base_callbackr"nemo.lightning.one_logger_callbackrr r(rKrr__all__r r r rs   u&