a h@sdZddlZddlZddlmZddlmZddlmZm Z ddl m Z m Z Gdddej ZeGd d d ZeGd d d ZeZe egdfe egdfd ddZe egdfe egdfd ddZdS)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) dataclassfield)AnyCallablec@seZdZdZdZdZdZdS)CallbackTriggerN)__name__ __module__ __qualname__ZDYNAMOZ LAZY_BACKWARDZTRITON_AUTOTUNINGZCUDAGRAPH_RECORDINGrrD/var/www/auris/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 ddZeegdfdd ddZeegdfdd ddZeddddZeddddZeeeedeefdddZddddZdS)CompilationCallbackHandler)default_factoryNstart_callbacks end_callbacksrF)defaultinitrepr6_CompilationCallbackHandler__pending_callbacks_counter)rrr;_CompilationCallbackHandler__pending_callbacks_counter_lockcallbackreturncCs|j||S)z Register a callback function to be called when the compilation starts. Args: - callback (Callable): The callback function to register. )rappendselfr rrrregister_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#rrrregister_end_callbackKs z0CompilationCallbackHandler.register_end_callbackcCs|j|dS)z Remove a registered start callback function. Args: - callback (Callable): The callback function to remove. N)rremover#rrrremove_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#rrrremove_end_callback`sz.CompilationCallbackHandler.remove_end_callback)argsr!cCs|jD] }||qdS)z9 Execute all registered start callbacks. N)rr$r*r rrrrun_start_callbacksis z.CompilationCallbackHandler.run_start_callbackscCs|jD] }||qdS)z7 Execute all registered end callbacks. N)rr+rrrrun_end_callbacksps z,CompilationCallbackHandler.run_end_callbacks)triggerrr!ccst||}z|j2|jdkr(|||jd7_Wdn1sJ0YdVW|jD|jdksvJd|jdkr|||jd8_Wdn1s0Yn^|jD|jdksJd|jdkr|||jd8_Wdn1s 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*rrrinstall_callbacksws*   ,   .   z,CompilationCallbackHandler.install_callbacks)r!cCs&|j|j|jdks"JdS)z1 Clear all registered callbacks. rN)rclearrr)r$rrrr0s  z CompilationCallbackHandler.clear)r rrrlistrrrrrrint threadingLockrr%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 rrron_compile_starts r7cCst||S)zS Decorator to register a callback function for the end of the compilation. )r5r&r6rrron_compile_ends r8)__doc__enumr3collections.abcr contextlibrZ dataclassesrrtypingrrEnumrrrr5r7r8rrrrs$   a