`i(ddlZddlmZddlmZddlmZmZeje Z gdZ dedefdZ ej fdedefd Z dd ed eed eefd ZdeeegefdeefdZdedefdZdedefdZGddZdS)Nwrapsunwrap)CallableOptional) PassManagerinplace_wrapperlog_hook loop_pass this_before_that_pass_constraint"these_before_those_pass_constraintfnreturnc<tfd}|S)z Convenience wrapper for passes which modify an object inplace. This wrapper makes them return the modified object instead. Args: fn (Callable[Object, Any]) Returns: wrapped_fn (Callable[Object, Object]) c||SN)gmrs p/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/torch/fx/passes/pass_manager.py wrapped_fnz#inplace_wrapper..wrapped_fn"s 2 r)rrs` rr r s6 2YYY rc@tfd}|S)a Logs callable output. This is useful for logging output of passes. Note inplace_wrapper replaces the pass output with the modified object. If we want to log the original output, apply this wrapper before inplace_wrapper. ``` def my_pass(d: Dict) -> bool: changed = False if "foo" in d: d["foo"] = "bar" changed = True return changed pm = PassManager(passes=[inplace_wrapper(log_hook(my_pass))]) ``` Args: fn (Callable[Type1, Type2]) level: logging level (e.g. logging.INFO) Returns: wrapped_fn (Callable[Type1, Type2]) cX|}td||S)NzRan pass %s Return value: %s)loggerlog)rvalrlevels rrzlog_hook..wrapped_fnGs.bff 5:BDDD rr)rrrs`` rr r *s<: 2YYY r base_passn_iter predicatecjduduz s Jdtfd}|S)aW Convenience wrapper for passes which need to be applied multiple times. Exactly one of `n_iter`or `predicate` must be specified. Args: base_pass (Callable[Object, Object]): pass to be applied in loop n_iter (int, optional): number of times to loop pass predicate (Callable[Object, bool], optional): Nz8Exactly one of `n_iter`or `predicate` must be specified.c|}$dkrtD] }|}n:"|r|}|ntddd|S)Nrz3loop_pass must be given positive int n_iter (given z) xor predicate (given ))range RuntimeError)sourceoutput_rr r!s rnew_passzloop_pass..new_passds  &1**6]] + +"6** +  ")F## +"6**)F## +???2;???  rr)rr r!r*s``` rr r Psr $ 9D#8 9B 9 9        Or constraintpassesct|D]S\}}t||dzdD]3\}}|||rtd|d|d|d|d|d|d TdS) Nz,pass schedule constraint violated. Expected z before z but found z at index z and z at indexz in pass list.) enumerater&)r+r,iajbs r"_validate_pass_schedule_constraintr4{s&!!1fQUWWo..  DAqz!Q q!+,34?@  rthisthatc4dtdtffd }|S)zd Defines a partial order ('depends on' function) where `this` must occur before `that`. r1r3c|kp|kSrr)r1r3r6r5s r depends_onz4this_before_that_pass_constraint..depends_onsDy%AI%rr)r5r6r9s`` rr r s= &h&8&&&&&&& rthesethosec4dtdtffd }|S)aQ Defines a partial order ('depends on' function) where `these` must occur before `those`. Where the inputs are 'unwrapped' before comparison. For example, the following pass list and constraint list would be invalid. ``` passes = [ loop_pass(pass_b, 3), loop_pass(pass_a, 5), ] constraints = [these_before_those_pass_constraint(pass_a, pass_b)] ``` Args: these (Callable): pass which should occur first those (Callable): pass which should occur later Returns: depends_on (Callable[[Object, Object], bool] r1r3cPt|kpt|kSrr)r1r3r;r<s rr9z6these_before_those_pass_constraint..depends_ons$ayyE!7VAYY%%77rr:)r;r<r9s`` rrrs=.8h888888888 rceZdZUdZeeed<eeed<dZeed< ddZ e dZ d efd Z d Z d eefd ZdZdZdZdS)r aT Construct a PassManager. Collects passes and constraints. This defines the pass schedule, manages pass constraints and pass execution. Args: passes (Optional[List[Callable]]): list of passes. A pass is a callable which modifies an object and returns modified object constraint (Optional[List[Callable]]): list of constraints. A constraint is a callable which takes two passes (A, B) and returns True if A depends on B and False otherwise. See implementation of `this_before_that_pass_constraint` for example. r, constraintsF _validatedNc*|pg|_|pg|_dSr)r,r@)selfr,r@s r__init__zPassManager.__init__s" l &,"rc$t|}|Sr)r )clsr,pms rbuild_from_passlistzPassManager.build_from_passlists   r_passcH|j|d|_dSNF)r,appendrA)rCrIs radd_passzPassManager.add_passs# 5!!!rcH|j|d|_dSrK)r@rLrArCr+s radd_constraintzPassManager.add_constraints$  +++r_passescRdSfd|jD}||_d|_dS)Nc&g|] }|jv |Sr)__name__).0psrQs r z+PassManager.remove_pass..s%NNNb2;g3M3Mr3M3M3MrF)r,rA)rCrQ passes_lefts ` r remove_passzPassManager.remove_passs: ? FNNNNDKNNN ! rcg}|jD]=}|j|jkr||(||>||_d|_dSrK)r,rTrLrA)rC_target _replacementrXrVs r replace_passzPassManager.replace_passsh + ' 'B{g...""<0000""2&&&&! rcd|jrdS|jD]}t||jd|_dS)z Validates that current pass schedule defined by `self.passes` is valid according to all constraints in `self.constraints` NT)rAr@r4r,rOs rvalidatezPassManager.validatesG ?  F* H HJ .z4; G G G Grc\||}|jD] }||}|Sr)r_r,)rCr'outrIs r__call__zPassManager.__call__s9 [  E%**CC rNN)rT __module__ __qualname____doc__listr__annotations__rAboolrD classmethodrHrMrPstrrYr]r_rbrrrr r s   NhJ----[  h        49          rr rc)logging functoolsrinspectrtypingrr getLoggerrTr__all__r INFOr intr rirgr4r rr rrrrts%%%%%%%%  8 $ $   X(")###(####P!$($$$ SM$!$$$$V (H-t34 >B8n     8 8    hx:KKKKKKKKKKr