(ti(ddlmZddlmZmZddlmZGddeZGddZGd d eZ Gd d eZ Gd deZ GddeZ GddeZ y))Any) ConfigMixinregister_to_config) CONFIG_NAMEczeZdZdZeZedfd Zede e fdZ de e e ffdZde e e ffdZxZS)PipelineCallbacka+ Base class for all the official callbacks used in a pipeline. This class provides a structure for implementing custom callbacks and ensures that all callbacks have a consistent interface. Please implement the following: `tensor_inputs`: This should return a list of tensor inputs specific to your callback. You will only be able to include variables listed in the `._callback_tensor_inputs` attribute of your pipeline class. `callback_fn`: This method defines the core functionality of your callback. ct|||| | td|3t|trd|cxkrdkstdtdyy)NzSEither cutoff_step_ratio or cutoff_step_index should be provided, not both or none.?z6cutoff_step_ratio must be a float between 0.0 and 1.0.)super__init__ ValueError isinstancefloat)selfcutoff_step_ratiocutoff_step_index __class__s b/Volumes/fast/ai/experiments/MLX_z-image/.venv/lib/python3.12/site-packages/diffusers/callbacks.pyrzPipelineCallback.__init__sz   %*;*C  ).?.Krs s  (,e4SDU=\Y\=\UV V>]UV V>] )returnc2td|j)Nz2You need to set the attribute `tensor_inputs` for NotImplementedErrorr)rs r tensor_inputszPipelineCallback.tensor_inputs#s!$VW[WeWeVf"ghhrc2td|j)Nz3You need to implement the method `callback_fn` for r)rpipeline step_index timestepscallback_kwargss r callback_fnzPipelineCallback.callback_fn's!$WX\XfXfWg"hiirc*|j||||SN)r")rrrtimestepr!s r__call__zPipelineCallback.__call__*s*hPPr)r N)__name__ __module__ __qualname____doc__r config_namerrpropertyliststrrdictrr"r& __classcell__)rs@rr r sw K W WitCyiijtTWY\T\~jQ4PSUXPX>Qrr cTeZdZdZdeefdZedeefdZ de ee ffdZ y)MultiPipelineCallbacksz This class is designed to handle multiple pipeline callbacks. It accepts a list of PipelineCallback objects and provides a unified interface for calling all of them. callbacksc||_yr$r3)rr3s rrzMultiPipelineCallbacks.__init__4s "rrch|jDcgc]}|jD]}|c}}Scc}}wr$)r3r)rcallbackinputs rrz$MultiPipelineCallbacks.tensor_inputs7s-&*nnYn((BXBXBXnYYYs.c>|jD] }|||||}|S)zr Calls all the callbacks in order with the given arguments and returns the final callback_kwargs. r5)rrrr%r!r7s rr&zMultiPipelineCallbacks.__call__;s*H&xXWO'rN) r'r(r)r*r-r rr,r.rr/rr&rrr2r2.sR #$'7"8#ZtCyZZ4PSUXPX>rr2c,eZdZdZdgZdeeeffdZy)SDCFGCutoffCallbacka. Callback function for Stable Diffusion Pipelines. After certain number of steps (set by `cutoff_step_ratio` or `cutoff_step_index`), this callback will disable the CFG. Note: This callback mutates the pipeline by changing the `_guidance_scale` attribute to 0.0 after the cutoff step. prompt_embedsrc|jj}|jj}||nt|j|z}||k(r0||j d}|dd}d|_|||j d<|S)Nrr configrrint num_timestepsr_guidance_scale) rrrr%r!rr cutoff_stepr=s rr"zSDCFGCutoffCallback.callback_fnOs KK99 KK99"3!> CH^H^arHrDs   $+D,>,>q,ABM)"#.M'*H $5BOD..q1 2rN r'r(r)r*rr/r.rr"r:rrr<r<Es(%%MdSVX[S[nrr<c.eZdZdZgdZdeeeffdZy)SDXLCFGCutoffCallbacka: Callback function for the base Stable Diffusion XL Pipelines. After certain number of steps (set by `cutoff_step_ratio` or `cutoff_step_index`), this callback will disable the CFG. Note: This callback mutates the pipeline by changing the `_guidance_scale` attribute to 0.0 after the cutoff step. )r=add_text_embeds add_time_idsrc|jj}|jj}||nt|j|z}||k(r||j d}|dd}||j d} | dd} ||j d} | dd} d|_|||j d<| ||j d<| ||j d<|S)Nrr?rr r@) rrrr%r!rrrEr=rIrJs rr"z!SDXLCFGCutoffCallback.callback_fnps KK99 KK99"3!> CH^H^arHrDs   $+D,>,>q,ABM)"#.M-d.@.@.CDO-bc2O*4+=+=a+@AL',L'*H $5BOD..q1 25DOD..q1 25AOD..q1 2rNrFr:rrrHrHbs%M dSVX[S[nrrHc.eZdZdZgdZdeeeffdZy)SDXLControlnetCFGCutoffCallbacka@ Callback function for the Controlnet Stable Diffusion XL Pipelines. After certain number of steps (set by `cutoff_step_ratio` or `cutoff_step_index`), this callback will disable the CFG. Note: This callback mutates the pipeline by changing the `_guidance_scale` attribute to 0.0 after the cutoff step. )r=rIrJimagerc|jj}|jj}||nt|j|z}||k(r||j d}|dd}||j d} | dd} ||j d} | dd} ||j d} | dd} d|_|||j d<| ||j d<| ||j d<| ||j d<|S)Nrr?rrLr r@) rrrr%r!rrrEr=rIrJrOs rr"z+SDXLControlnetCFGCutoffCallback.callback_fns6 KK99 KK99"3!> CH^H^arHrDs   $+D,>,>q,ABM)"#.M-d.@.@.CDO-bc2O*4+=+=a+@AL',L$D$6$6q$9:E"#JE'*H $5BOD..q1 25DOD..q1 25AOD..q1 25:OD..q1 2rNrFr:rrrNrNs%MdSVX[S[nrrNc*eZdZdZgZdeeeffdZy)IPAdapterScaleCutoffCallbackaQ Callback function for any pipeline that inherits `IPAdapterMixin`. After certain number of steps (set by `cutoff_step_ratio` or `cutoff_step_index`), this callback will set the IP Adapter scale to `0.0`. Note: This callback mutates the IP Adapter attention processors by setting the scale to 0.0 after the cutoff step. rc|jj}|jj}||nt|j|z}||k(r|j d|S)Nr )rArrrBrCset_ip_adapter_scale)rrrr%r!rrrEs rr"z(IPAdapterScaleCutoffCallback.callback_fnsc KK99 KK99"3!> CH^H^arHrDs   $  ) )# .rNrFr:rrrSrSs%M dSVX[S[n rrSc.eZdZdZddgZdeeeffdZy)SD3CFGCutoffCallbacka0 Callback function for Stable Diffusion 3 Pipelines. After certain number of steps (set by `cutoff_step_ratio` or `cutoff_step_index`), this callback will disable the CFG. Note: This callback mutates the pipeline by changing the `_guidance_scale` attribute to 0.0 after the cutoff step. r=pooled_prompt_embedsrcR|jj}|jj}||nt|j|z}||k(rY||j d}|dd}||j d} | dd} d|_|||j d<| ||j d<|S)Nrr?rr r@) rrrr%r!rrrEr=rXs rr"z SD3CFGCutoffCallback.callback_fns KK99 KK99"3!> CH^H^arHrDs   $+D,>,>q,ABM)"#.M#243E3Ea3H#I #7$ (+H $5BOD..q1 25IOD..q1 2rNrFr:rrrWrWs+%&<=MdSVX[S[nrrWN)typingrconfiguration_utilsrrutilsrr r2r<rHrNrSrWr:rrr]sj@$Q{$QN.*:','T-&6-`#30 + r