o h@sdZddlZddlmZddlmZddlmZmZddl m Z m Z m Z ddl mZeGdd d ZeZd e gdfd e gdffd d Zd e gdfd e gdffddZdS)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)AnyCallableOptional)justknobs_checkc@sXeZdZUeedZeegdfed<eedZeegdfed<eddddZ e e ed<eddddZ e ed <eejddd Zejed <d egdfd egdffddZd egdfd egdffddZd egdfd dfddZd egdfd dfddZd ddZd ddZed e fddZed edeeffddZd ddZdS)!CompilationCallbackHandler)default_factoryNstart_callbacks end_callbacksF)defaultinitrepr8_CompilationCallbackHandler__prevent_duplicate_callbacksr6_CompilationCallbackHandler__pending_callbacks_counter)r rr;_CompilationCallbackHandler__pending_callbacks_counter_lockcallbackreturncC|j||S)z Register a callback function to be called when the compilation starts. Args: - callback (Callable): The callback function to register. )r appendselfrrj/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/torch/_dynamo/callback.pyregister_start_callback2s z2CompilationCallbackHandler.register_start_callbackcCr)z Register a callback function to be called when the compilation ends. Args: - callback (Callable): The callback function to register. )r rrrrrregister_end_callback>s z0CompilationCallbackHandler.register_end_callbackcC|j|dS)z Remove a registered start callback function. Args: - callback (Callable): The callback function to remove. N)r removerrrrremove_start_callbackHz0CompilationCallbackHandler.remove_start_callbackcCr)z Remove a registered end callback function. Args: - callback (Callable): The callback function to remove. N)r rrrrrremove_end_callbackQr!z.CompilationCallbackHandler.remove_end_callbackcC|jD]}|qdS)z9 Execute all registered start callbacks. N)r rrrrrun_start_callbacksZ z.CompilationCallbackHandler.run_start_callbackscCr#)z7 Execute all registered end callbacks. N)r rrrrrun_end_callbacksar%z,CompilationCallbackHandler.run_end_callbackscCs|jdur td|_|jS)Nz*pytorch/dynamo:prevent_duplicate_callbacks)rr rrrrprevent_duplicate_callbackshs z6CompilationCallbackHandler.prevent_duplicate_callbacksccs:|jrzW|j|jdkr||jd7_Wdn1s#wYdVW|j!|jdks9Jd|jdkrB||jd8_Wdn 1sSwYdSdS|j!|jdksiJd|jdkrr||jd8_Wdw1swYwz|dVW|dS|w)zc Context manager to install the callbacks and run them when the context is exited. rNz1Pending callbacks counter cannot become negative.)r(rrr$r&r'rrrinstall_callbacksps8   ,  z,CompilationCallbackHandler.install_callbackscCs|j|jdS)z1 Clear all registered callbacks. N)r clearr r'rrrr+s z CompilationCallbackHandler.clear)rN)__name__ __module__ __qualname__rlistr r__annotations__r rrboolrint threadingLockrrrr r"r$r&propertyr(rrrr*r+rrrrr %s2    "   r rrcCt||S)zU Decorator to register a callback function for the start of the compilation. )callback_handlerrrrrron_compile_start r9cCr6)zS Decorator to register a callback function for the end of the compilation. )r7rr8rrron_compile_endr:r;)__doc__r3collections.abcr contextlibr dataclassesrrtypingrrrtorch._utils_internalr r r7r9r;rrrrs   m"&