a Ç ÀhÒã@sÔdZddlZddlZddlmZddlmZddlmZm Z ddl m Z m Z Gdd„dej ƒZeGd d „d ƒƒZeGd d „d ƒƒZeƒZe egdfe egdfd œdd„Ze egdfe egdfd œdd„ZdS)a  This module provides callback management functionality for TorchDynamo's compilation process. It implements a thread-safe system for registering, managing and executing callbacks that run at the start and end of TorchDynamo compilations. Key features include: - Registration and deregistration of compilation callbacks - Thread-safe callback handling with proper locking mechanisms - Prevention of duplicate callback execution when configured - Decorator utilities for easy callback registration - Context manager for controlled callback lifecycle The module centers around the CompilationCallbackHandler class which maintains separate lists for start and end callbacks, manages their execution order, and ensures thread-safety. Utility decorators @on_compile_start and @on_compile_end provide a convenient way to register compilation hooks. Example usage: @on_compile_start def my_start_callback(): print("Starting compilation") @on_compile_end def my_end_callback(): print("Compilation complete") éN)Ú Generator)Úcontextmanager)Ú dataclassÚfield)ÚAnyÚCallablec@seZdZdZdZdZdZdS)ÚCallbackTriggerééééN)Ú__name__Ú __module__Ú __qualname__ZDYNAMOZ LAZY_BACKWARDZTRITON_AUTOTUNINGZCUDAGRAPH_RECORDING©rrúR/var/www/html/assistant/venv/lib/python3.9/site-packages/torch/_dynamo/callback.pyr$src@seZdZUeed<eed<dS)Ú CallbackArgsZcallback_triggerÚ compile_idN)r rrrÚ__annotations__Ústrrrrrr/s rc@sHeZdZUeedZeeegdfed<eedZ eeegdfed<eddddZ e ed<ee j ddd Ze j ed <eegdfeegdfd œd d „Zeegdfeegdfd œdd„Zeegdfdd œdd„Zeegdfdd œdd„Zeddœdd„Zeddœdd„Zeeeedeefdœdd„ƒZddœdd„ZdS)ÚCompilationCallbackHandler)Údefault_factoryNÚstart_callbacksÚ end_callbacksrF)ÚdefaultÚinitÚreprÚ6_CompilationCallbackHandler__pending_callbacks_counter)rrrÚ;_CompilationCallbackHandler__pending_callbacks_counter_lock©ÚcallbackÚreturncCs|j |¡|S)z© Register a callback function to be called when the compilation starts. Args: - callback (Callable): The callback function to register. )rÚappend©Úselfr rrrÚregister_start_callback?s z2CompilationCallbackHandler.register_start_callbackcCs|j |¡|S)z§ Register a callback function to be called when the compilation ends. Args: - callback (Callable): The callback function to register. )rr"r#rrrÚregister_end_callbackKs z0CompilationCallbackHandler.register_end_callbackcCs|j |¡dS)z Remove a registered start callback function. Args: - callback (Callable): The callback function to remove. N)rÚremover#rrrÚremove_start_callbackWsz0CompilationCallbackHandler.remove_start_callbackcCs|j |¡dS)z‹ Remove a registered end callback function. Args: - callback (Callable): The callback function to remove. N)rr'r#rrrÚremove_end_callback`sz.CompilationCallbackHandler.remove_end_callback)Úargsr!cCs|jD] }||ƒqdS)z9 Execute all registered start callbacks. N)r©r$r*r rrrÚrun_start_callbacksis z.CompilationCallbackHandler.run_start_callbackscCs|jD] }||ƒqdS)z7 Execute all registered end callbacks. N)rr+rrrÚrun_end_callbacksps z,CompilationCallbackHandler.run_end_callbacks)Útriggerrr!ccst||ƒ}z¬|j2|jdkr(| |¡|jd7_Wdƒn1sJ0YdVW|jD|jdksvJdƒ‚|jdkrŠ| |¡|jd8_Wdƒn1s¬0Yn^|jD|jdksÒJdƒ‚|jdkræ| |¡|jd8_Wdƒn1s 0Y0dS)zc Context manager to install the callbacks and run them when the context is exited. rr Nz1Pending callbacks counter cannot become negative.)rrrr,r-)r$r.rr*rrrÚinstall_callbacksws*   , ÿ  .ú ÿ  z,CompilationCallbackHandler.install_callbacks)r!cCs&|j ¡|j ¡|jdks"J‚dS)z1 Clear all registered callbacks. rN)rÚclearrr)r$rrrr0Žs  z CompilationCallbackHandler.clear)r rrrÚlistrrrrrrÚintÚ threadingÚLockrr%r&r(r)r,r-rrrrrr/r0rrrrr5s*   ÿ  þ  þ    þrrcCst |¡|S)zU Decorator to register a callback function for the start of the compilation. )Úcallback_handlerr%©r rrrÚon_compile_startšs r7cCst |¡|S)zS Decorator to register a callback function for the end of the compilation. )r5r&r6rrrÚon_compile_end¤s r8)Ú__doc__Úenumr3Úcollections.abcrÚ contextlibrÚ dataclassesrrÚtypingrrÚEnumrrrr5r7r8rrrrÚs$   a  þ  þ