Remove vae_cache

Author: Perseus14

src/maxdiffusion/pipelines/wan/wan_pipeline.py

@@ -28,7 +28,7 @@
 from ...max_utils import get_flash_block_sizes, get_precision, device_put_replicated
 from ...models.wan.wan_utils import load_wan_transformer, load_wan_vae
 from ...models.wan.transformers.transformer_wan import WanModel
-from ...models.wan.autoencoder_kl_wan import AutoencoderKLWan, AutoencoderKLWanCache
+from ...models.wan.autoencoder_kl_wan import AutoencoderKLWan
 from maxdiffusion.video_processor import VideoProcessor
 from ...schedulers.scheduling_unipc_multistep_flax import FlaxUniPCMultistepScheduler, UniPCMultistepSchedulerState
 from transformers import AutoTokenizer, UMT5EncoderModel
@@ -196,7 +196,6 @@ def __init__(
       text_encoder: UMT5EncoderModel,
       transformer: WanModel,
       vae: AutoencoderKLWan,
-      vae_cache: AutoencoderKLWanCache,
       scheduler: FlaxUniPCMultistepScheduler,
       scheduler_state: UniPCMultistepSchedulerState,
       devices_array: np.array,
@@ -207,7 +206,6 @@ def __init__(
     self.text_encoder = text_encoder
     self.transformer = transformer
     self.vae = vae
-    self.vae_cache = vae_cache
     self.scheduler = scheduler
     self.scheduler_state = scheduler_state
     self.devices_array = devices_array
@@ -275,8 +273,7 @@ def create_model(rngs: nnx.Rngs, config: HyperParameters):
     state = nnx.from_flat_state(state)
 
     wan_vae = nnx.merge(graphdef, state)
-    vae_cache = AutoencoderKLWanCache(wan_vae)
-    return wan_vae, vae_cache
+    return wan_vae
 
   @classmethod
   def get_basic_config(cls, dtype, config: HyperParameters):
@@ -396,14 +393,13 @@ def from_checkpoint(cls, config: HyperParameters, restored_checkpoint=None, vae_
       scheduler, scheduler_state = cls.load_scheduler(config=config)
 
     with mesh:
-      wan_vae, vae_cache = cls.load_vae(devices_array=devices_array, mesh=mesh, rngs=rngs, config=config)
+      wan_vae = cls.load_vae(devices_array=devices_array, mesh=mesh, rngs=rngs, config=config)
 
     return WanPipeline(
         tokenizer=tokenizer,
         text_encoder=text_encoder,
         transformer=transformer,
         vae=wan_vae,
-        vae_cache=vae_cache,
         scheduler=scheduler,
         scheduler_state=scheduler_state,
         devices_array=devices_array,
@@ -433,14 +429,13 @@ def from_pretrained(cls, config: HyperParameters, vae_only=False, load_transform
       scheduler, scheduler_state = cls.load_scheduler(config=config)
 
     with mesh:
-      wan_vae, vae_cache = cls.load_vae(devices_array=devices_array, mesh=mesh, rngs=rngs, config=config)
+      wan_vae = cls.load_vae(devices_array=devices_array, mesh=mesh, rngs=rngs, config=config)
 
     pipeline = WanPipeline(
         tokenizer=tokenizer,
         text_encoder=text_encoder,
         transformer=transformer,
         vae=wan_vae,
-        vae_cache=vae_cache,
         scheduler=scheduler,
         scheduler_state=scheduler_state,
         devices_array=devices_array,
@@ -629,7 +624,7 @@ def __call__(
         latents = latents.astype(jnp.float32)
 
     with self.mesh, nn_partitioning.axis_rules(self.config.logical_axis_rules):
-      video = self.vae.decode(latents, self.vae_cache)[0]
+      video = self.vae.decode(latents, return_dict=False)[0]
 
     video = jnp.transpose(video, (0, 4, 1, 2, 3))
     video = jax.experimental.multihost_utils.process_allgather(video, tiled=True)