Wj0ddlZddlmZddlmZddlmZddlmZej e Z gdZ dedefd Z ejfdedefd Z dd ed eed eefdZdeeegefdeefdZdedefdZdedefdZGddZdS)NCallablewrapsunwrap)Optional) 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 a/home/longshao/multi-rider-rag/.venv/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_fnHs.bff 5:BDDD rr)rrrs`` rr r +s<: 2YYY r base_passn_iter predicatectduduz stdtfd}|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_passds  &1**6]] + +"6** +  ")F## +"6**)F## +???2;???  r)AssertionErrorr)r r!r"r+s``` rr r Qsk 4 IT$9 :YWXXX 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_constraintr6{s&!!1fQUWWo..  DAqz!Q q!+,34?@  rthisthatc4dtdtffd }|S)zd Defines a partial order ('depends on' function) where `this` must occur before `that`. r3r5c|kp|kSrr)r3r5r8r7s r depends_onz4this_before_that_pass_constraint..depends_onsDy%AI%rr)r7r8r;s`` rrrs= &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] r3r5cPt|kpt|kSrr)r3r5r<r=s rr;z6these_before_those_pass_constraint..depends_ons$ayyE!7VAYY%%77rr)r<r=r;s`` 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.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_passescRdSfd|jD}||_d|_dS)Nc&g|] }|jv |Sr)__name__).0psrRs r z+PassManager.remove_pass..s%NNNb2;g3M3Mr3M3M3MrF)r.rB)rDrR passes_lefts ` r remove_passzPassManager.remove_passs: ? FNNNNDKNNN ! rcg}|jD]=}|j|jkr||(||>||_d|_dSrL)r.rUrMrB)rD_target _replacementrYrWs 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)rBrAr6r.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__listr__annotations__rBboolrE classmethodrIrNrQstrrZr^r`rcrrrr r s   NhJ----[  h        49          rr rd)loggingcollections.abcr functoolsrinspectrtypingr getLoggerrUr__all__r INFOr intr rjrhr6rrr rrrrvs$$$$$$  8 $ $   X(")###(####P!$(### SM#!####T (H-t34 >B8n     8 8    hx:KKKKKKKKKKr