קg(ddlmZddlmZddlmZmZmZddlZej e Z gdZ dedefdZ ejfdedefd Zdd ed eed eefd ZdeeegefdeefdZdedefdZdedefdZGddZdS)wrapsunwrap)CallableListOptionalN) 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)gmvalrs X/var/www/html/ai-engine/env/lib/python3.11/site-packages/torch/fx/passes/pass_manager.py wrapped_fnz#inplace_wrapper..wrapped_fn sbff 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)rrrlevels rrzlog_hook..wrapped_fnFs.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_r r!r"s rnew_passzloop_pass..new_pass`s  &1**6]] + +"6** +  ")F## +"6**)F## +???2;???  rr)r r!r"r+s``` rr r Ps| $  BBABBB 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_constraintr5ws&!!1fQUWWo..  DAqz!Q q!+,34?@  rthisthatc4dtdtffd }|S)zd Defines a partial order ('depends on' function) where `this` must occur before `that`. r2r4c|kp|kSrr)r2r4r7r6s r depends_onz4this_before_that_pass_constraint..depends_onsDy%AI%rr)r6r7r:s`` rrrs= &h&8&&&&&&& rthesethosec4dtdtffd }|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] r2r4cPt|kpt|kSrr)r2r4r<r=s rr:z6these_before_those_pass_constraint..depends_ons$ayyE!7VAYY%%77rr;)r<r=r:s`` rrrs=28h888888888 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-rA)selfr-rAs r__init__zPassManager.__init__s" l &,"rc$t|}|Sr)r )clsr-pms rbuild_from_passlistzPassManager.build_from_passlists   r_passcH|j|d|_dSNF)r-appendrB)rDrJs radd_passzPassManager.add_passs# 5!!!rcH|j|d|_dSrL)rArMrBrDr,s radd_constraintzPassManager.add_constraints$  +++r_passesc~|dSg}|jD] }|j|vr||!||_d|_dSrLr-__name__rMrB)rDrR passes_leftpss r remove_passzPassManager.remove_passsV ? F + ' 'B{'))""2&&&! rcg}|jD]=}|j|jkr||(||>||_d|_dSrLrT)rD_target _replacementrVrWs 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)rBrAr5r-rPs rvalidatezPassManager.validatesG ?  F* H HJ .z4; G G G Grc\||}|jD] }||}|Sr)r^r-)rDr(outrJs r__call__zPassManager.__call__s9 [  E%**CC rNN)rU __module__ __qualname____doc__rr__annotations__rBboolrE classmethodrIrNrQstrrXr\r^rarrrr r s   NhJ----[  h        49          rr rb) functoolsrinspectrtypingrrr logging getLoggerrUr__all__r INFOr intr rgr5rrr rrrrrs++++++++++  8 $ $   X&")%%%(%%%%R   8C= HU]L^    N (H-t34 >B8n     8 8    hx>NNNNNNNNNNr