+ Lj.^RIt^RIHt^RIt^RIHt^RIHt]!]4t !RR4t !RR4t !R R 4t !R R 4t !R R4tR#)N)Any) get_logger) unwrap_modulec2a]tRt^toV3RlRltRtVtR#) BaseStatec<V^8dQhRR/#returnN)format __classdict__s"A/app/.local/lib/python3.14/site-packages/diffusers/hooks/hooks.py __annotate__BaseState.__annotate__s   c\R4h)zWBaseState::reset is not implemented. Please implement this method in the derived class.)NotImplementedError)selfargskwargss&*,rresetBaseState.resets! e  rr N)__name__ __module__ __qualname____firstlineno__r__static_attributes____classdictcell__rs@rrrs  rrc`a]tRt^"toR V3RlRlltRtV3RlRltV3RlRltR tVt R#) StateManagerNc <V^8dQhRS[/#)r state_cls)r)r rs"rrStateManager.__annotate__#s%%)%rcbWnVeTMRVnVeTM/Vn/VnRVnR#)Nr ) _state_cls _init_args _init_kwargs _state_cache_current_context)rr$ init_args init_kwargss&&&&r__init__StateManager.__init__#s4#'0'<)"+6+BK $rc:VPf \R4hVPVPP49d>VP!VP /VP BVPVP&VPVP,#)NzDNo context is set. Please set a context before retrieving the state.)r+ ValueErrorr*keysr'r(r)rs&r get_stateStateManager.get_state*s}  (cd d  (9(9(>(>(@ @7;7m[_[l[l7mD  d33 4  !6!677rc$<V^8dQhRS[RR/#r namer Nstr)r rs"rrr%1s%%%%rcWnR#N)r+rr8s&&r set_contextStateManager.set_context1s $rc<V^8dQhRR/#r r )r rs"rrr%4s%%%rc\VPP44F2wr4VP!V/VBVPP V4K4 RVnR#r<)listr*itemsrpopr+)rrrr8states&*, rrStateManager.reset4sQ 1 1 7 7 9:KD KK ( (    ! !$ ';!%r)r+r(r)r*r')NN) rrrrr.r4r>rrrr s@rr"r""s(%%8%%%%rr"ca]tRt^;toRtRtRtV3RlRltV3RlRltV3RlR lt V3R lR lt V3R lR lt V3RlRlt V3RlRlt RtVtR#) ModelHookzd A hook that contains callbacks to be executed just before and after the forward method of a model. FcRVnR#r<fn_refr3s&rr.ModelHook.__init__Bs /3 rcv<V^8dQhRS[PPRS[PP/#r moduler torchnnModule)r rs"rrModelHook.__annotate__Es+ehhoo%((//rc V#)z Hook that is executed when a model is initialized. Args: module (`torch.nn.Module`): The module attached to this hook. r rrOs&&rinitialize_hookModelHook.initialize_hookE  rcv<V^8dQhRS[PPRS[PP/#rNrP)r rs"rrrTOs+uxx588??rc V#)z Hook that is executed when a model is deinitialized. Args: module (`torch.nn.Module`): The module attached to this hook. r rVs&&rdeinitalize_hookModelHook.deinitalize_hookOrYrc<V^8dQhRS[PPRS[S[S[,S[S[S[3,3,/#rN)rQrRrStuplerdictr:)r rs"rrrTYs?%((//uUSVZY]^acf^fYgMgGhrc W#3#)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 )rrOrrs&&*,r pre_forwardModelHook.pre_forwardYs |rcT<V^8dQhRS[PPRS[RS[/#)r rOoutputr )rQrRrSr)r rs"rrrTjs*  588?? C C rc V#)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 )rrOres&&&r post_forwardModelHook.post_forwardjs  rcv<V^8dQhRS[PPRS[PP/#rNrP)r rs"rrrTxs+%((//ehhoorc V#)z Hook that is executed when the hook is detached from a module. Args: module (`torch.nn.Module`): The module detached from this hook. r rVs&&r detach_hookModelHook.detach_hookxrYrcH<V^8dQhRS[PP/#)r rOrP)r rs"rrrTs%((//rc@VP'd \R4hV#)zFThis hook is stateful and needs to implement the `reset_state` method.) _is_statefulrrVs&&r reset_stateModelHook.reset_states    %&no o rcR<V^8dQhRS[PPRS[RR/#)r rOr8r N)rQrRrSr:)r rs"rrrTs*588??#$rc\V4F7p\W4p\V\4'gK&VP V4K9 V#r<)dirgetattr isinstancer"r>)rrOr8 attr_nameattrs&&& r _set_contextModelHook._set_contexts<TI4+D$ --  &# rrJN)rrrr__doc__ror.rWr\rbrgrkrpryrrr s@rrHrH;s\L4"   rrHc2a]tRt^toV3RlRltRtVtR#)HookFunctionReferencec<V^8dQhRR/#r r )r rs"rr"HookFunctionReference.__annotate__s%%$%rc >RVnRVnRVnRVnR#)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)rbrgforwardoriginal_forwardr3s&rr.HookFunctionReference.__init__s#    $r)rrrgrbN)rrrrr.rrr s@rr}r}s%%rr}caa]tRt^toV3RlV3RlltV3RlRltV3RlRltRV3RlRlltRV3R lR llt] V3R lR l4t RV3R lRllt V3RlRlt V3RlRlt RtVtV;t#) HookRegistrycL<V^8dQhRS[PPRR/#)r module_refr NrP)r rs"rrHookRegistry.__annotate__s#588??trcZ<\SV`4/VnWn.Vn.VnR#r<)superr.hooks _module_ref _hook_order_fn_refs)rr __class__s&&rr.HookRegistry.__init__s* +- % rc*<V^8dQhRS[RS[RR/#)r hookr8r N)rHr:)r rs"rrrs"&%&%)&%3&%4&%rc6W PP49d\RV R24hVPVP4VnRRlpVPP p\ 4pVPVnVPVnWEn\VR4'dVWEn \P!\P!VPVP4VP4VnV!V4p\P!\P!W`P4V4VPnWQnWPV&VP P#V4VP$P#V4R#)zHook 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.c$V^8dQhR\/#)r function_reference)r})r s"rr0HookRegistry.register_hook..__annotate__s  3H rcaV3RlpV#)cz<SP!V.VO5/VBwrSP!V/VBpSPW4#r<)rbrrg)rOrrrers&*, r new_forwardKHookRegistry.register_hook..create_new_forward..new_forwardsE1==fVtVvV +33TDVD)66vFFrr )rrsf rcreate_new_forward6HookRegistry.register_hook..create_new_forwards G  rrN)rr2r1rWrrr}rbrghasattrr functoolsupdate_wrapperpartialrrKrappendr)rrr8rrrKrewritten_forwards&&& r register_hookHookRegistry.register_hooksO ::??$ $!$(IJ   //0@0@A ""**&(!--"//  4 ' '&- #&55!!$"2"2D4D4DEtGWGWFN/v6#,#;#;   /1A1A BDU$    4 % V$rc4<V^8dQhRS[RS[R,/#r7)r:rH)r rs"rrrs **S*Y%5*rc:VPPVR4#r<)rgetr=s&&rget_hookHookRegistry.get_hookszz~~dD))rc*<V^8dQhRS[RS[RR/#)r r8recurser N)r:bool)r rs"rrrs'LLLdLdLrcHWPP49Ed\VP4pVPV,pVPP V4pVP V,pVP pVPe VPpWS^, 8XdWpPnMWpP V^,,nVPVP4VnVPVVPPV4VP PV4V'd`VPP4F?wrVR8XdK\V R4'gK"V PPVRR7KA R#R#)N_diffusers_hookFr)rr2lenrindexrrrrr\rD named_modulesrr remove_hook) rr8r num_hooksrrrK old_forward module_namerOs &&& 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$<V^8dQhRS[RR/#)r rr N)r)r rs"rrrs O OD OD Orc\VP4FEpVPV,pVP'gK*VP VP 4KG V'ds\ VP 4P4FIwrEVR8XdK\ V4p\VR4'gK-VPPRR7KK R#R#)rrFrN) reversedrrrorprrrrrreset_stateful_hooks)rr hook_namerrrOs&& rr!HookRegistry.reset_stateful_hookss!$"2"23I::i(D     !1!124 '4T5E5E'F'T'T'V# "$&v.6#455**???N (W rcL<V^8dQhRS[PPRR/#)r rOr rrP)r rs"rrrs#&&588??&~&rcX\VR4'gV!V4VnVP#)r)rr)clsrOs&&rcheck_if_exists_or_initialize*HookRegistry.check_if_exists_or_initializes(v011%([F "%%%rc2<V^8dQhRS[R,RR/#)r r8Nr r9)r rs"rrr s((t(t(rc\VP4FFpVPV,pVP'gK*VP VP V4KH VP 4FpVP V4K R#r<)rrrroryr_get_child_registries)rr8rrregistrys&& rryHookRegistry._set_context sj!$"2"23I::i(D   !!$"2"2D94 224H  ! !$ '5rc.<V^8dQhRS[R,/#)r r r)rB)r rs"rrrstN';rc Z\VR4'gRVnVPe VP#.p\VP4P 4FHwr#VR8XdK\V4p\VR4'gK-VP VP 4KJ WnV#)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)rrrrrrr)r registriesrrOs& rr"HookRegistry._get_child_registriesst677+/D (  ' ' 3// / #01A1A#B#P#P#R Kb "6*Fv011!!&"8"89 $S (2$rc <V^8dQhRS[/#)r r r9)r rs"rrr,s 4 4# 4rcRp\VP4Fwr#VPV,PP\ PJd#VPV,P 4pM'VPV,PP pVRV RV RV 2, pV\VP4^, 8gKVR, pK RV R2#)rz (z) z -  zHookRegistry( z )) enumeraterrr__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)rrrrr)Tr<)rrrrr.rrrr classmethodrryrrrr __classcell__)rrs@@rrrss&%&%P**LL8 O O&& ((. 4 4 4rr)rtypingrrQ utils.loggingrutils.torch_utilsrrloggerrr"rHr}rr rrrsY &- H   %%2RRj%%.O4O4r