o ei@sddlZddlmZddlmZddlmZddlmZe e Z gdZ dedefd d Z ejfdedefd d Z  d d edeedeefddZdeeegefdeefddZdedefddZdedefddZGdddZdS)!NCallablewrapsunwrap)Optional) PassManagerinplace_wrapperlog_hook loop_pass this_before_that_pass_constraint"these_before_those_pass_constraintfnreturncstfdd}|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]) cs ||SN)gmrrf/var/www/addictedbytheproject.nl/epg/venv/lib/python3.10/site-packages/torch/fx/passes/pass_manager.py wrapped_fn#sz#inplace_wrapper..wrapped_fnr)rrrrrr s r cstfdd}|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]) cs|}td||S)NzRan pass %s Return value: %s)loggerlog)rvalrlevelrrrHszlog_hook..wrapped_fnr)rrrrrrr +sr base_passn_iter predicatecs4duduAs tdtfdd}|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.csh|}durdkrtD]}|}q|Sdur)|r'|}|s|Stddd)Nrz3loop_pass must be given positive int n_iter (given z) xor predicate (given ))range RuntimeError)sourceoutput_rrrrrnew_passds"   zloop_pass..new_pass)AssertionErrorr)rrrr&rr%rr Qs r constraintpassescCslt|D]/\}}t||ddD] \}}|||rqtd|d|d|d|d|d|d qdS) 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)iajbrrr"_validate_pass_schedule_constraint{s" r0thisthatcdtdtffdd }|S)zd Defines a partial order ('depends on' function) where `this` must occur before `that`. r-r/cs|kp|kSrrr-r/r2r1rr depends_onsz4this_before_that_pass_constraint..depends_onr)r1r2r6rr5rr sr thesethosecr3)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] r-r/cst|kp t|kSrrr4r7r8rrr6sz6these_before_those_pass_constraint..depends_onr)r7r8r6rr9rrsrc@seZdZUdZeeed<eeed<dZeed<  dddZ e d d Z d efd d Z ddZ deefddZddZddZddZdS)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 _validatedNcCs|pg|_|pg|_dSr)r)r:)selfr)r:rrr__init__s zPassManager.__init__cCs t|}|Sr)r )clsr)pmrrrbuild_from_passlistszPassManager.build_from_passlist_passcC|j|d|_dSNF)r)appendr;)r<rArrradd_pass  zPassManager.add_passcCrBrC)r:rDr;r<r(rrradd_constraintrFzPassManager.add_constraint_passescs0durdSfdd|jD}||_d|_dS)Ncsg|] }|jvr|qSr)__name__).0psrIrr sz+PassManager.remove_pass..F)r)r;)r<rI passes_leftrrMr remove_passs  zPassManager.remove_passcCsBg}|jD]}|j|jkr||q||q||_d|_dSrC)r)rJrDr;)r<_target _replacementrOrLrrr replace_passs     zPassManager.replace_passcCs,|jrdS|jD]}t||jqd|_dS)z Validates that current pass schedule defined by `self.passes` is valid according to all constraints in `self.constraints` NT)r;r:r0r)rGrrrvalidates   zPassManager.validatecCs$||}|jD]}||}q |Sr)rTr))r<r"outrArrr__call__s   zPassManager.__call__NN)rJ __module__ __qualname____doc__listr__annotations__r;boolr= classmethodr@rErHstrrPrSrTrVrrrrr s       r rW)loggingcollections.abcr functoolsrinspectrtypingr getLoggerrJr__all__r INFOr intr r]r[r0r rr rrrrs4      ( *