U JcT@sddlmZddlmZddlmZmZddlZee Z eedddZ ej feeddd Z deeed d d Zeeegefeed ddZeedddZeedddZGdddZdS)wrapsunwrap)CallableListN)fnreturncstfdd}|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 |}|SNZgmvalrr @/tmp/pip-unpacked-wheel-gikjz4vx/torch/fx/passes/pass_manager.py wrapped_fnsz#inplace_wrapper..wrapped_fnr)rrr rrinplace_wrapper s rcstfdd}|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$|}tdd||S)Nz Ran pass z Return value: )loggerlogr rlevelr rr=szlog_hook..wrapped_fnr)rrrr rrlog_hooksr base_passn_iter predicatecs4dk dk Astdtfdd}|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.csb|}dk r,dkr,tD] }|}qn2dk rH|r^|}q4ntddd|S)Nrz3loop_pass must be given positive int n_iter (given z) xor predicate (given ))range RuntimeError)sourceoutput_rr rnew_passWs   zloop_pass..new_pass)AssertionErrorr)rrrr!r rr loop_passGs r#) constraintpassescCsnt|D]`\}}t||ddD]B\}}|||r8q$td|d|d|d|d|d|d q$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%iajbr r r"_validate_pass_schedule_constraintns (r,)thisthatcsttdfdd }|S)zd Defines a partial order ('depends on' function) where `this` must occur before `that`. r)r+cs|kr|krdSdSNFTr r/r.r-r r depends_onsz4this_before_that_pass_constraint..depends_onr)r-r.r2r r1r this_before_that_pass_constraint|sr4thesethosecsttdfdd }|S)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/cs t|krt|krdSdSr0rr/r5r rr2sz6these_before_those_pass_constraint..depends_onr3)r6r7r2r r5r"these_before_those_pass_constraintsr8c@seZdZUdZgZeeed<gZeeed<dZ e ed<dddZ e d d Z ed d d ZddZeedddZddZddZdS) PassManageraT 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|r ||_|r||_dSr )r%r:)selfr%r:r r r__init__szPassManager.__init__cCs t|}|Sr )r9)clsr%Zpmr r rbuild_from_passlistszPassManager.build_from_passlist)_passcCs|j|d|_dSNF)r%appendr;)r<r@r r radd_passs zPassManager.add_passcCs|j|d|_dSrA)r:rBr;r<r$r r radd_constraints zPassManager.add_constraint)_passescCs@|dkr dSg}|jD]}|j|kr||q||_d|_dSrA)r%__name__rBr;)r<rFZ passes_leftZpsr r r remove_passs   zPassManager.remove_passcCs,|jr dS|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:r,r%rDr r rvalidates  zPassManager.validatecCs$||}|jD] }||}q|Sr )rIr%)r<routr@r r r__call__s   zPassManager.__call__)NN)rG __module__ __qualname____doc__r%rr__annotations__r:r;boolr= classmethodr?rCrErHrIrKr r r rr9s      r9)NN) functoolsrinspectrtypingrrlogging getLoggerrGrrINFOrintr#rPr,r4r8r9r r r rs   )( !