wangbo/ComfyUI
1
0
Fork 0
mirror of https://github.com/comfyanonymous/ComfyUI.git synced 2026-04-27 10:52:31 +08:00
Code Issues Actions 10 Packages Projects Releases Wiki Activity

ltx: vae: save un-actionable chunks to RunUpState.

Browse Source
This commit is contained in:
Rattus 2026-04-08 10:09:43 +10:00
parent ce054bbf2d
commit 4ba0b9125d
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
comfy/ldm/lightricks/vae/causal_video_autoencoder.py
View File

@ -23,6 +23,7 @@ class RunUpState:
self.checkpoint_fn = checkpoint_fn
self.max_chunk_size = max_chunk_size
self.output_frames = output_frames
self.pending_samples = []
def in_meta_context():
return torch.device("meta") == torch.empty(0).device
@ -595,14 +596,13 @@ class Decoder(nn.Module):
self.run_up(idx + 1, next_sample_ref, ended, run_up_state, output_buffer, output_offset)
return
else:
samples = torch.chunk(sample, chunks=num_chunks, dim=2)
samples = list(torch.chunk(sample, chunks=num_chunks, dim=2))
#This loop might need to become a while.
#If the output buffer is exhausted (or none), it need to stash whatever is left of the samples
#list to new state.
#exhaustion is detectable here with output_offset[0] vs output_buffer shape in T.
for chunk_idx, sample1 in enumerate(samples):
self.run_up(idx + 1, [sample1], ended and chunk_idx == len(samples) - 1, run_up_state, output_buffer, output_offset)
while len(samples):
if output_buffer is None or output_offset[0] == output_buffer.shape[2]:
run_up_state.pending_samples.append((idx + 1, samples, ended))
return
self.run_up(idx + 1, [samples.pop(0)], ended and len(samples) == 1, run_up_state, output_buffer, output_offset)
def forward_orig(
self,