o j9:j@sddlZddlmZddlmZddlmZeeZ gdZ dedefdd Z ej fdedefd d Z  dd ed edBdedBfddZdeeegefdeefddZdedefddZdedefddZGdddZdS) NCallablewrapsunwrap) 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)gmrrc/home/nk/hobo-godmode/plappi-mvp/.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``. Example:: 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)rvalrlevelrrrFszlog_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_passbs"   zloop_pass..new_pass)AssertionErrorr)rrrr%rr$rr Os 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_constraintys" r/thisthatcdtdtffdd }|S)zd Defines a partial order ('depends on' function) where `this` must occur before `that`. r,r.cs|kp|kSrrr,r.r1r0rr depends_onsz4this_before_that_pass_constraint..depends_onr)r0r1r5rr4rr sr thesethosecr2)a\ 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|kSrrr3r6r7rrr5sz6these_before_those_pass_constraint..depends_onr)r6r7r5rr8rr sr c@seZdZUdZeeed<eeed<dZeed<  dddZ e d d Z d efd d Z ddZ deefddZddZddZddZdS)raT 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(r9)selfr(r9rrr__init__s zPassManager.__init__cCs t|}|Sr)r)clsr(pmrrrbuild_from_passlistszPassManager.build_from_passlist_passcC|j|d|_dSNF)r(appendr:)r;r@rrradd_pass  zPassManager.add_passcCrArB)r9rCr:r;r'rrradd_constraintrEzPassManager.add_constraint_passescs0durdSfdd|jD}||_d|_dS)Ncsg|] }|jvr|qSr)__name__).0psrHrr sz+PassManager.remove_pass..F)r(r:)r;rH passes_leftrrLr remove_passs  zPassManager.remove_passcCsBg}|jD]}|j|jkr||q||q||_d|_dSrB)r(rIrCr:)r;_target _replacementrNrKrrr 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:r9r/r(rFrrrvalidates   zPassManager.validatecCs$||}|jD]}||}q |Sr)rSr()r;r!outr@rrr__call__s   zPassManager.__call__NN)rI __module__ __qualname____doc__listr__annotations__r:boolr< classmethodr?rDrGstrrOrRrSrUrrrrrs       rrV)loggingcollections.abcr functoolsrinspectr getLoggerrIr__all__r INFOr intr r\rZr/r r rrrrrs2     ' *