bip+ddlZddlmZmZmZmZddlZddlmZddl m Z ee Z GddZ Gdd ZGd d ZGd d ZGddZy)N)AnyDictOptionalTuple) get_logger) unwrap_moduleceZdZddZy) BaseStateNctd)NzWBaseState::reset is not implemented. Please implement this method in the derived class.)NotImplementedError)selfargskwargss P/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/diffusers/hooks/hooks.pyresetzBaseState.resets! e  returnN)__name__ __module__ __qualname__rrrr r s rr c8eZdZd defdZdZdeddfdZd dZy) StateManagerN state_clscZ||_||nd|_||ni|_i|_d|_y)Nr) _state_cls _init_args _init_kwargs _state_cache_current_context)rr init_args init_kwargss r__init__zStateManager.__init__#s6#'0'<)"+6+BK $rc(|j td|j|jjvr=|j|j i|j |j|j<|j|jS)NzDNo context is set. Please set a context before retrieving the state.)r" ValueErrorr!keysrrr rs r get_statezStateManager.get_state*s  (cd d  (9(9(>(>(@ @7Ft7m[_[l[l7mD  d33 4  !6!677rnamerc||_yN)r"rr+s r set_contextzStateManager.set_context1s $rct|jjD]2\}}|j|i||jj |4d|_yr-)listr!itemsrpopr")rrrr+states rrzStateManager.reset4sZ 1 1 7 7 9: (KD% EKK ( (    ! !$ ' (!%r)NNr) rrrr r%r*strr/rrrrrr"s+%)%8%%%%rrc8eZdZdZdZdZdejjdejjfdZ dejjdejjfdZ dejjde e e e ee fffdZdejjd e de fd Zdejjdejjfd Zdejjfd Zdejjd eddfdZy) ModelHookzl A hook that contains callbacks to be executed just before and after the forward method of a model. Fcd|_yr-)fn_refr)s rr%zModelHook.__init__Bs /3 rmodulerc|S)z Hook that is executed when a model is initialized. Args: module (`torch.nn.Module`): The module attached to this hook. rrr:s rinitialize_hookzModelHook.initialize_hookE  rc|S)z Hook that is executed when a model is deinitialized. Args: module (`torch.nn.Module`): The module attached to this hook. rr<s rdeinitalize_hookzModelHook.deinitalize_hookOr>rc ||fS)a$ Hook that is executed just before the forward method of the model. Args: module (`torch.nn.Module`): The module whose forward pass will be executed just after this event. args (`Tuple[Any]`): The positional arguments passed to the module. kwargs (`Dict[Str, Any]`): The keyword arguments passed to the module. Returns: `Tuple[Tuple[Any], Dict[Str, Any]]`: A tuple with the treated `args` and `kwargs`. r)rr:rrs r pre_forwardzModelHook.pre_forwardYsV|routputc|S)a` Hook that is executed just after the forward method of the model. Args: module (`torch.nn.Module`): The module whose forward pass been executed just before this event. output (`Any`): The output of the module. Returns: `Any`: The processed `output`. r)rr:rCs r post_forwardzModelHook.post_forwardjs  rc|S)z Hook that is executed when the hook is detached from a module. Args: module (`torch.nn.Module`): The module detached from this hook. rr<s r detach_hookzModelHook.detach_hookxr>rc4|jr td|S)NzFThis hook is stateful and needs to implement the `reset_state` method.) _is_statefulr r<s r reset_statezModelHook.reset_states   %&no o rr+Nct|D]0}t||}t|ts |j |2|Sr-)dirgetattr isinstancerr/)rr:r+ attr_nameattrs r _set_contextzModelHook._set_contexts@T 'I4+D$ -  & ' r)rrr__doc__rIr%torchnnModuler=r@rrrr5rBrErGrJrQrrrr7r7;s L4ehhoo%((//uxx588??%((//uUSVZY]^acf^fYgMgGh" 588?? C C %((//ehhoo%((// 588??#$rr7ceZdZddZy)HookFunctionReferenceNc<d|_d|_d|_d|_y)aA container class that maintains mutable references to forward pass functions in a hook chain. Its mutable nature allows the hook system to modify the execution chain dynamically without rebuilding the entire forward pass structure. Attributes: pre_forward: A callable that processes inputs before the main forward pass. post_forward: A callable that processes outputs after the main forward pass. forward: The current forward function in the hook chain. original_forward: The original forward function, stored when a hook provides a custom new_forward. The class enables hook removal by allowing updates to the forward chain through reference modification rather than requiring reconstruction of the entire chain. When a hook is removed, only the relevant references need to be updated, preserving the execution order of the remaining hooks. N)rBrEforwardoriginal_forwardr)s rr%zHookFunctionReference.__init__s#    $rr)rrrr%rrrrWrWs%rrWceZdZdejj ddffd ZdededdfdZ dede efdZ dded e ddfd Z dd e ddfd Zed ejj ddfd Zdde eddfdZdefdZxZS) HookRegistry module_refrNcZt|i|_||_g|_g|_yr-)superr%hooks _module_ref _hook_order_fn_refs)rr] __class__s rr%zHookRegistry.__init__s, +- % rhookr+c.||jjvrtd|d|j|j|_dt fd}|jj }t }|j|_|j|_||_t|drT||_ tjtj|j|j|j|_||}tjtj||j||j_||_||j|<|j j#||j$j#|y)NzHook with name zv already exists in the registry. Please use a different name or first remove the existing hook and then add a new one.function_referencecfd}|S)Nc~j|g|i|\}}j|i|}j||Sr-)rBrYrE)r:rrrCrgs r new_forwardzKHookRegistry.register_hook..create_new_forward..new_forwardsO=1==fVtVvV f3+33TDVD)66vvFFrr)rgrjs` rcreate_new_forwardz6HookRegistry.register_hook..create_new_forwards G  rrj)r`r(r'r=rarWrYrBrEhasattrrZ functoolsupdate_wrapperpartialrjr9rbappendrc)rrer+rkrYr9rewritten_forwards r register_hookzHookRegistry.register_hooks` 4::??$ $!$(IJ   //0@0@A 3H ""**&(!--"//  4 '&-F #&55!!$"2"2D4D4DEtGWGWFN/v6#,#;#;   /1A1A BDU$    4 % V$rc:|jj|dSr-)r`getr.s rget_hookzHookRegistry.get_hookszz~~dD))rrecursec||jjvrt|j}|j|}|jj |}|j |}|j }|j |j}||dz k(r||j_n||j |dz_|j|j|_|j|=|jj||j j||rS|jjD]5\}} |dk(r t| ds| jj|d7yy)N_diffusers_hookFrv)r`r(lenrbindexrcrYrZrar@r3 named_modulesrlrz remove_hook) rr+rv num_hooksrer}r9 old_forward module_namer:s rrzHookRegistry.remove_hooksM 4::??$ $D,,-I::d#D$$**40E]]5)F ..K&&2$55  A %+6  (3> eai(0#44T5E5EFD  4     ' MM  e $ '+'7'7'E'E'G L# V"$6#45**66tU6K  L rcvt|jD]9}|j|}|js|j |j ;|rft |j jD]?\}}|dk(r t |}t|ds$|jjdAyy)NryrzFr{) reversedrbr`rIrJrar r~rlrzreset_stateful_hooks)rrv hook_namererr:s rrz!HookRegistry.reset_stateful_hookss!$"2"23 3I::i(D    !1!12 3 '4T5E5E'F'T'T'V O# V"$&v.6#45**???N  O rr:cLt|ds |||_|jS)Nrz)rlrz)clsr:s rcheck_if_exists_or_initializez*HookRegistry.check_if_exists_or_initializes%v01%([F "%%%rcpt|jD]:}|j|}|js|j |j |<t |j jD]>\}}|dk(r t |}t|ds$|jj |@y)Nryrz) rrbr`rIrQrar r~rlrz)rr+rrerr:s rrQzHookRegistry._set_context s!$"2"23 :I::i(D  !!$"2"2D9 : $11A1A#B#P#P#R : Kb "6*Fv01&&33D9  :rcd}t|jD]\}}|j|jjt jur|j|j }n#|j|jj }|d|d|d|z }|t|jdz ks|dz }d|dS) Nryz (z) z - rx zHookRegistry( z )) enumeraterbr`rd__repr__objectrr|)r registry_reprir hook_reprs rrzHookRegistry.__repr__s %d&6&67 &LAyzz)$..77vN JJy1::<  JJy1;;DD s1#R {#i[A AM3t''(1,,%  &!s33r)Tr-)rrrrSrTrUr%r7r5rrrruboolrr classmethodrrQr __classcell__)rds@rr\r\s588??t&%)&%3&%4&%P*S*Xi%8*LLdLdL8 OD OD O&588??&~&& :# :$ : 4# 4rr\)rmtypingrrrrrS utils.loggingrutils.torch_utilsr rloggerr rr7rWr\rrrrs\-- &- H   %%2RRj%%.|4|4r