VhdZddlZddlmZddlmZddlmZmZddl m Z m Z m Z ddl mZeGdd ZeZd e gdfd e gdffd Zd e gdfd e gdffd Zy)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_checkceZdZUeeZeegdfed<eeZeegdfed<edddZ e e ed<edddZ e ed <eejdd Zejed <d egdfd egdffdZd egdfd egdffdZd egdfd dfdZd egdfd dfdZddZddZed e fdZed edeeffdZddZy)CompilationCallbackHandler)default_factoryNstart_callbacks end_callbacksF)defaultinitrepr8_CompilationCallbackHandler__prevent_duplicate_callbacksr6_CompilationCallbackHandler__pending_callbacks_counter)r rr;_CompilationCallbackHandler__pending_callbacks_counter_lockcallbackreturnc<|jj||S)z Register a callback function to be called when the compilation starts. Args: - callback (Callable): The callback function to register. )rappendselfrs F/home/dcms/DCMS/lib/python3.12/site-packages/torch/_dynamo/callback.pyregister_start_callbackz2CompilationCallbackHandler.register_start_callback2s ##H-c<|jj||S)z Register a callback function to be called when the compilation ends. Args: - callback (Callable): The callback function to register. )rrrs rregister_end_callbackz0CompilationCallbackHandler.register_end_callback>s !!(+rc:|jj|y)z Remove a registered start callback function. Args: - callback (Callable): The callback function to remove. N)rremovers rremove_start_callbackz0CompilationCallbackHandler.remove_start_callbackHs ##H-rc:|jj|y)z Remove a registered end callback function. Args: - callback (Callable): The callback function to remove. N)rr"rs rremove_end_callbackz.CompilationCallbackHandler.remove_end_callbackQs !!(+rc4|jD] }| y)z9 Execute all registered start callbacks. N)rrs rrun_start_callbacksz.CompilationCallbackHandler.run_start_callbacksZs,, H J rc4|jD] }| y)z7 Execute all registered end callbacks. N)rrs rrun_end_callbacksz,CompilationCallbackHandler.run_end_callbacksas** H J rcR|jtd|_|jS)Nz*pytorch/dynamo:prevent_duplicate_callbacks)rr rs rprevent_duplicate_callbacksz6CompilationCallbackHandler.prevent_duplicate_callbackshs,  - - 51@<2D .111rc#K|jr |j5|jdk(r|j|xjdz c_dddd|j5|jdkDsJd|jdk(r|j |xjdzc_dddy |jd|j y#1swYxYw#1swYyxYw#|j5|jdkDsJd|jdk(r|j |xjdzc_dddw#1swYwxYwxYw#|j wxYww)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+s rinstall_callbacksz,CompilationCallbackHandler.install_callbackspsh  + + ::::771<0024494::::;;a?K?771<..04494 :: )((*&&(%:: ::T:::;;a?K?771<..04494 :::&&(s} F C;5C# C; F)A C/4 F>E+F#C,(C;/C84F; E(A E E(E% !E((F+E==Fcl|jj|jjy)z1 Clear all registered callbacks. N)rclearrr+s rr1z CompilationCallbackHandler.clears( ""$   "r)rN)__name__ __module__ __qualname__rlistrr__annotations__rrr boolrint threadingLockrrr r#r%r'r)propertyr,rrrr/r1rrr r %se05d0KOT(2t8,-K.3D.IM4T*+I495u5!8D>(-QU'OO7<!U8$inn  T*  "d(  hr4x.@XbRVhEW.hr4x.@.T.,HRX,>,4,2T22)9T3^#<))4#rr rrc0tj||S)zU Decorator to register a callback function for the start of the compilation. )callback_handlerrrs ron_compile_startr@s,,X6 Orc0tj||S)zS Decorator to register a callback function for the end of the compilation. )r>r r?s ron_compile_endrBs**84 Or)__doc__r9collections.abcr contextlibr dataclassesrrtypingrrr torch._utils_internalr r r>r@rBr<rrrIs6%%(**1 j#j# j#Z./xD1hr4x6HXb$h/HRX4Fr