3j.SSKrSSKJr SSKrSSKJr SSKJr \"\5r "SS5r "SS 5r "S S 5r "S S 5r "SS5rg)N)Any) get_logger) unwrap_modulec\rSrSrSSjrSrg) BaseStateNc[S5e)NzWBaseState::reset is not implemented. Please implement this method in the derived class.)NotImplementedError)selfargskwargss O/home/wildlama/miniconda3/lib/python3.13/site-packages/diffusers/hooks/hooks.pyresetBaseState.resets! e  returnN)__name__ __module__ __qualname____firstlineno__r__static_attributes__rrrrrs rrcH\rSrSrS S\4SjjrSrS\SS4SjrS S jr S r g) StateManager"N state_clsc\XlUbUOSUlUbUO0Ul0UlSUlg)Nr) _state_cls _init_args _init_kwargs _state_cache_current_context)r r init_args init_kwargss r__init__StateManager.__init__#s4#'0'<)"+6+BK $rc.URc [S5eURURR5;a=UR"UR 0UR D6URUR'URUR$)NzDNo context is set. Please set a context before retrieving the state.)r$ ValueErrorr#keysr r!r"r s r get_stateStateManager.get_state*s}  (cd d  (9(9(>(>(@ @7;7m[_[l[l7mD  d33 4  !6!677rnamercXlgN)r$r r/s r set_contextStateManager.set_context1s $rc[URR55H2up4UR"U0UD6 URR U5 M4 SUlgr1)listr#itemsrpopr$)r r rr/states rrStateManager.reset4sQ 1 1 7 7 9:KD KK ( (    ! !$ ';!%r)r$r!r"r#r )NNr) rrrrrr'r-strr3rrrrrrr"s+%)%8%%%%rrcN\rSrSrSrSrSrS\RRS\RR4Sjr S\RRS\RR4Sjr S\RRS\ \ \ \\\ 444S jrS\RRS \ S\ 4S jrS\RRS\RR4S jrS\RR4S jrS\RRS\SS4SjrSrg) ModelHook;zd A hook that contains callbacks to be executed just before and after the forward method of a model. FcSUlgr1fn_refr,s rr'ModelHook.__init__Bs /3 rmodulercU$)z Hook that is executed when a model is initialized. Args: module (`torch.nn.Module`): The module attached to this hook. rr rCs rinitialize_hookModelHook.initialize_hookE  rcU$)z Hook that is executed when a model is deinitialized. Args: module (`torch.nn.Module`): The module attached to this hook. rrEs rdeinitalize_hookModelHook.deinitalize_hookOrHrcX#4$)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)r rCr rs r pre_forwardModelHook.pre_forwardYs |routputcU$)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)r rCrOs r post_forwardModelHook.post_forwardjs  rcU$)z Hook that is executed when the hook is detached from a module. Args: module (`torch.nn.Module`): The module detached from this hook. rrEs r detach_hookModelHook.detach_hookxrHrc>UR(a [S5eU$)NzFThis hook is stateful and needs to implement the `reset_state` method.) _is_statefulr rEs r reset_stateModelHook.reset_states   %&no o rr/Nc[U5H6n[X5n[U[5(dM%UR U5 M8 U$r1)dirgetattr isinstancerr3)r rCr/ attr_nameattrs r _set_contextModelHook._set_contexts<TI4+D$ --  &# rr@)rrrr__doc__rWr'torchnnModulerFrJtuplerdictr;rMrQrTrXr`rrrrr=r=;s L4ehhoo%((//uxx588??%((//uUSVZY]^acf^fYgMgGh" 588?? C C %((//ehhoo%((// 588??#$rr=c\rSrSrSSjrSrg)HookFunctionReferenceNc<SUlSUlSUlSUlg)a^A 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)rMrQforwardoriginal_forwardr,s rr'HookFunctionReference.__init__s#    $r)rlrmrQrMr)rrrrr'rrrrriris%rric<^\rSrSrS\R R SS4U4SjjrS\S\ SS4Sjr S\ S\S-4S jr SS\ S \ SS4S jjr SS \ SS4S jjr\S \R R SS4Sj5rSS\ S-SS4SjjrS\S4SjrS\ 4SjrSrU=r$) HookRegistry module_refrNcX>[TU]5 0UlXl/Ul/Ulgr1)superr'hooks _module_ref _hook_order_fn_refs)r rr __class__s rr'HookRegistry.__init__s* +- % rhookr/c:X RR5;a[SUS35eURUR5UlS[ 4SjnURR n[ 5nURUlURUlXEl[US5(aUXEl [R"[R"URUR5UR5UlU"U5n[R"[R"X`R5U5URlXQlXRU'UR R#U5 UR$R#U5 g)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_referencec^U4SjnU$)Ncz>TR"U/UQ70UD6upTR"U0UD6nTRX5$r1)rMrlrQ)rCr rrOr}s r new_forwardKHookRegistry.register_hook..create_new_forward..new_forwardsE1==fVtVvV +33TDVD)66vFFrr)r}rs` rcreate_new_forward6HookRegistry.register_hook..create_new_forwards G  rr)rur+r*rFrvrirlrMrQhasattrrm functoolsupdate_wrapperpartialrrArwappendrx)r r{r/rrlrArewritten_forwards r register_hookHookRegistry.register_hooksW ::??$ $!$(IJ   //0@0@A 3H ""**&(!--"//  4 ' '&- #&55!!$"2"2D4D4DEtGWGWFN/v6#,#;#;   /1A1A BDU$    4 % V$rc:URRUS5$r1)rugetr2s rget_hookHookRegistry.get_hookszz~~dD))rrecursec XRR5;Ga[UR5nURUnURR U5nUR UnUR nURb URnXSS- :XaXpRlOXpR US-lURUR5UlURU URRU5 UR RU5 U(aYURR5H:upUS:XaM [U S5(dM U RRUSS9 M< gg)N_diffusers_hookFr)rur+lenrwindexrxrlrmrvrJr8 named_modulesrr remove_hook) r r/r num_hooksr{rrA old_forward module_namerCs rrHookRegistry.remove_hooks@ ::??$ $D,,-I::d#D$$**40E]]5)F ..K&&2$55 A %+6  (3> eai(0#44T5E5EFD  4     ' MM  e $ '+'7'7'E'E'G# "$6#455**66tU6K (H rc[UR5H@nURUnUR(dM%UR UR 5 MB U(al[ UR 5R5HDupEUS:XaM [ U5n[US5(dM+URRSS9 MF gg)NrrFr) reversedrwrurWrXrvrrrrreset_stateful_hooks)r r hook_namer{rrCs rr!HookRegistry.reset_stateful_hookss!$"2"23I::i(D     !1!124 '4T5E5E'F'T'T'V# "$&v.6#455**???N (W rrCcV[US5(d U"U5UlUR$)Nr)rr)clsrCs rcheck_if_exists_or_initialize*HookRegistry.check_if_exists_or_initializes(v011%([F "%%%rc[UR5HAnURUnUR(dM%UR UR U5 MC UR 5HnUR U5 M gr1)rrwrurWr`rv_get_child_registries)r r/rr{registrys rr`HookRegistry._set_context sj!$"2"23I::i(D   !!$"2"2D94 224H  ! !$ '5rcR[US5(dSUlURb UR$/n[UR5R 5HFup#US:XaM [U5n[US5(dM+UR UR 5 MH XlU$)a7Return registries of child modules, using a cached list when available. The cache is built on first call and reused for subsequent calls. This avoids the cost of walking the full module tree via named_modules() on every _set_context call, which is significant for large models (e.g. ~2.7ms per call on Flux2). _child_registries_cacheNrr)rrrrvrrr)r registriesrrCs rr"HookRegistry._get_child_registriesst677+/D (  ' ' 3// / #01A1A#B#P#P#R Kb "6*Fv011!!&"8"89 $S (2$rcSn[UR5Hup#URURR[ RLaURUR 5nO#URURR nUSUSUSU3- nU[UR5S- :dMUS- nM SUS3$) Nrz (z) z - r zHookRegistry( z )) enumeraterwrury__repr__objectrr)r registry_reprir hook_reprs rrHookRegistry.__repr__,s %d&6&67LAzz)$..77vN JJy1::<  JJy1;;DD s1#R {#i[A AM3t''(1,,% 8!s33r)rrxrwrvru)Tr1)rrrrrcrdrer'r=r;rrboolrr classmethodrr`r6rrr __classcell__)rys@rrprps588??t&%)&%3&%4&%P*S*Y%5*LLdLdL8 OD OD O&588??&~&& (t(t(tN';. 4# 4 4rrp)rtypingrrc utils.loggingrutils.torch_utilsrrloggerrrr=rirprrrrsY &- H   %%2RRj%%.O4O4r