94057c3d3e
PR Test (NPU) / check-changes (push) Has been cancelled
PR Test (NPU) / pr-gate (push) Has been cancelled
PR Test (NPU) / set-image-config (push) Has been cancelled
PR Test (NPU) / stage-b-test-1-npu-a2 (0) (push) Has been cancelled
PR Test (NPU) / stage-b-test-1-npu-a2 (1) (push) Has been cancelled
PR Test (NPU) / stage-b-test-2-npu-a2 (0) (push) Has been cancelled
PR Test (NPU) / stage-b-test-2-npu-a2 (1) (push) Has been cancelled
PR Test (NPU) / stage-b-test-4-npu-a3 (push) Has been cancelled
PR Test (NPU) / stage-b-test-16-npu-a3 (push) Has been cancelled
PR Test (NPU) / multimodal-gen-test-1-npu-a3 (push) Has been cancelled
PR Test (NPU) / multimodal-gen-test-2-npu-a3 (push) Has been cancelled
PR Test (Arm64) / pr-gate (push) Has been cancelled
PR Test (Arm64) / check-changes (push) Has been cancelled
PR Test (Arm64) / build-test (push) Has been cancelled
PR Test (sgl-router) / gate (push) Has been cancelled
PR Test (sgl-router) / tier-1 — lint (push) Has been cancelled
PR Test (sgl-router) / tier-2 — build + test (push) Has been cancelled
PR Test (sgl-router) / tier-3 — docker (placeholder) (push) Has been cancelled
PR Test (sgl-router) / tier-3 — k8s integration (push) Has been cancelled
PR Test (sgl-router) / tier-3 — e2e (push) Has been cancelled
PR Test (sgl-router) / finish (push) Has been cancelled
PR Test (NPU) / single-node-poc (map[name:qwen3_6_27b_w8a8_1p_in64k_out1k_50ms runner:linux-aarch64-a3-2 test_case:test/registered/ascend/performance/qwen3_6_27b/test_npu_qwen3_6_27b_w8a8_1p_in64k_out1k_50ms.py test_type:perf]) (push) Has been cancelled
PR Test (NPU) / pr-test-npu-finish (push) Has been cancelled
PR Test (Xeon) / pr-gate (push) Has been cancelled
PR Test (Xeon) / check-changes (push) Has been cancelled
PR Test (Xeon) / build-test (, xeon-gnr, base-b-test-cpu) (push) Has been cancelled
PR Test (XPU) / check-changes (push) Has been cancelled
PR Test (XPU) / pr-gate (push) Has been cancelled
PR Test (XPU) / stage-a-test-1-gpu-xpu (push) Has been cancelled
PR Test (XPU) / wait-for-stage-a (push) Has been cancelled
PR Test (XPU) / stage-b-test-1-gpu-xpu (push) Has been cancelled
PR Test (XPU) / finish (push) Has been cancelled
CI Model Inventory / build-inventory (push) Has been cancelled
Lint / lint (push) Has been cancelled
PR Benchmark (SMG Components) / Benchmark Compilation Check (push) Has been cancelled
PR Benchmark (SMG Components) / Benchmark - Manual Policy (push) Has been cancelled
PR Benchmark (SMG Components) / Benchmark - Request Processing (push) Has been cancelled
PR Benchmark (SMG Components) / Benchmark Summary (push) Has been cancelled
PR Test (SMG) / build-wheel (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on windows (x86_64 - auto) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on macos (x86_64 - auto) (push) Has been cancelled
PR Test (SMG) / python-unit-tests (push) Has been cancelled
PR Test (SMG) / unit-tests (push) Has been cancelled
PR Test (SMG) / benchmarks (push) Has been cancelled
PR Test (SMG) / chat-completions (push) Has been cancelled
PR Test (SMG) / chat-completions-4gpu (push) Has been cancelled
PR Test (SMG) / e2e (push) Has been cancelled
PR Test (SMG) / docker-build-test (push) Has been cancelled
PR Test (SMG) / k8s-integration (push) Has been cancelled
PR Test (SMG) / finish (push) Has been cancelled
PR Test (SMG) / summarize-benchmarks (push) Has been cancelled
Release SGLang Model Gateway Docker Image / publish (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on macos (aarch64 - auto) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on linux (aarch64 - auto) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on linux (x86_64 - auto) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on linux (aarch64 - musllinux_1_1) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / build on linux (x86_64 - musllinux_1_1) (push) Has been cancelled
Release SGLang Model Gateway to PyPI / Build SDist (push) Has been cancelled
Release SGLang Model Gateway to PyPI / Upload to PyPI (push) Has been cancelled
Release SGLang Kernels / build-cu129-matrix (aarch64, 12.9, 3.10, arm-kernel-build-node) (push) Has been cancelled
Release SGLang Kernels / build-cu129-matrix (x86_64, 12.9, 3.10, x64-kernel-build-node) (push) Has been cancelled
Release SGLang Kernels / release-cu129 (push) Has been cancelled
Release SGLang Kernels / build-cu130-matrix (aarch64, 13.0, 3.10, arm-kernel-build-node) (push) Has been cancelled
Release SGLang Kernels / build-cu130-matrix (x86_64, 13.0, 3.10, x64-kernel-build-node) (push) Has been cancelled
Release SGLang Kernels / release-cu130 (push) Has been cancelled
Release SGLang Kernels / build-rocm-matrix (3.10, 700) (push) Has been cancelled
Release SGLang Kernels / build-rocm-matrix (3.10, 720) (push) Has been cancelled
Release SGLang Kernels / release-rocm700 (push) Has been cancelled
Release SGLang Kernels / release-rocm720 (push) Has been cancelled
Release SGLang Kernels / build-musa43 (43, 3.10) (push) Has been cancelled
Release SGLang Kernels / release-musa43 (push) Has been cancelled
1692 lines
54 KiB
Python
1692 lines
54 KiB
Python
# Copied and adapted from: https://github.com/hao-ai-lab/FastVideo
|
|
|
|
# SPDX-License-Identifier: Apache-2.0
|
|
|
|
# Copyright 2025 The Wan Team and The HuggingFace Team. All rights reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
|
|
import contextvars
|
|
from contextlib import contextmanager, nullcontext
|
|
|
|
import torch
|
|
import torch.distributed as dist
|
|
import torch.nn as nn
|
|
import torch.nn.functional as F
|
|
from einops import rearrange
|
|
|
|
from sglang.multimodal_gen.configs.models.vaes import WanVAEConfig
|
|
from sglang.multimodal_gen.configs.models.vaes.base import (
|
|
should_use_spatial_shard_parallel_decode,
|
|
)
|
|
from sglang.multimodal_gen.runtime.distributed.parallel_state import (
|
|
get_decode_parallel_rank,
|
|
get_decode_parallel_world_size,
|
|
get_sp_parallel_rank,
|
|
get_sp_world_size,
|
|
)
|
|
from sglang.multimodal_gen.runtime.layers.activation import get_act_fn
|
|
from sglang.multimodal_gen.runtime.layers.parallel_conv import (
|
|
SpatialParallelCausalConv3d,
|
|
SpatialParallelConv2d,
|
|
SpatialParallelZeroPad2d,
|
|
causal_conv3d_cat_pad,
|
|
chunk_height_for_parallel_decode,
|
|
disable_spatial_parallel_decode,
|
|
gather_and_trim_height,
|
|
gather_height_for_global_op,
|
|
split_for_parallel_decode,
|
|
)
|
|
from sglang.multimodal_gen.runtime.models.vaes.common import (
|
|
DiagonalGaussianDistribution,
|
|
ParallelTiledVAE,
|
|
should_run_spatial_shard_parallel_decode,
|
|
)
|
|
from sglang.multimodal_gen.runtime.platforms import current_platform
|
|
|
|
CACHE_T = 2
|
|
|
|
is_first_frame = contextvars.ContextVar("is_first_frame", default=False)
|
|
feat_cache = contextvars.ContextVar("feat_cache", default=None)
|
|
feat_idx = contextvars.ContextVar("feat_idx", default=0)
|
|
first_chunk = contextvars.ContextVar("first_chunk", default=None)
|
|
|
|
|
|
def _channels_last_3d_supported_by_platform() -> bool:
|
|
return hasattr(torch, "channels_last_3d") and (
|
|
current_platform.is_cuda() or current_platform.is_rocm()
|
|
)
|
|
|
|
|
|
def _conv3d_weight_is_channels_last_3d(weight: torch.Tensor) -> bool:
|
|
return (
|
|
weight.dim() == 5
|
|
and _channels_last_3d_supported_by_platform()
|
|
and weight.is_contiguous(memory_format=torch.channels_last_3d)
|
|
)
|
|
|
|
|
|
def match_conv3d_input_format(x: torch.Tensor, weight: torch.Tensor) -> torch.Tensor:
|
|
if x.dim() == 5 and _conv3d_weight_is_channels_last_3d(weight):
|
|
return x.contiguous(memory_format=torch.channels_last_3d)
|
|
return x
|
|
|
|
|
|
class AvgDown3D(nn.Module):
|
|
def __init__(
|
|
self,
|
|
in_channels,
|
|
out_channels,
|
|
factor_t,
|
|
factor_s=1,
|
|
):
|
|
super().__init__()
|
|
self.in_channels = in_channels
|
|
self.out_channels = out_channels
|
|
self.factor_t = factor_t
|
|
self.factor_s = factor_s
|
|
self.factor = self.factor_t * self.factor_s * self.factor_s
|
|
|
|
assert in_channels * self.factor % out_channels == 0
|
|
self.group_size = in_channels * self.factor // out_channels
|
|
|
|
def forward(self, x: torch.Tensor) -> torch.Tensor:
|
|
pad_t = (self.factor_t - x.shape[2] % self.factor_t) % self.factor_t
|
|
pad = (0, 0, 0, 0, pad_t, 0)
|
|
x = F.pad(x, pad)
|
|
B, C, T, H, W = x.shape
|
|
x = x.view(
|
|
B,
|
|
C,
|
|
T // self.factor_t,
|
|
self.factor_t,
|
|
H // self.factor_s,
|
|
self.factor_s,
|
|
W // self.factor_s,
|
|
self.factor_s,
|
|
)
|
|
x = x.permute(0, 1, 3, 5, 7, 2, 4, 6).contiguous()
|
|
x = x.view(
|
|
B,
|
|
C * self.factor,
|
|
T // self.factor_t,
|
|
H // self.factor_s,
|
|
W // self.factor_s,
|
|
)
|
|
x = x.view(
|
|
B,
|
|
self.out_channels,
|
|
self.group_size,
|
|
T // self.factor_t,
|
|
H // self.factor_s,
|
|
W // self.factor_s,
|
|
)
|
|
x = x.mean(dim=2)
|
|
return x
|
|
|
|
|
|
class DupUp3D(nn.Module):
|
|
def __init__(
|
|
self,
|
|
in_channels: int,
|
|
out_channels: int,
|
|
factor_t,
|
|
factor_s=1,
|
|
):
|
|
super().__init__()
|
|
self.in_channels = in_channels
|
|
self.out_channels = out_channels
|
|
|
|
self.factor_t = factor_t
|
|
self.factor_s = factor_s
|
|
self.factor = self.factor_t * self.factor_s * self.factor_s
|
|
|
|
assert out_channels * self.factor % in_channels == 0
|
|
self.repeats = out_channels * self.factor // in_channels
|
|
|
|
def forward(self, x: torch.Tensor) -> torch.Tensor:
|
|
x = x.repeat_interleave(self.repeats, dim=1)
|
|
x = x.view(
|
|
x.size(0),
|
|
self.out_channels,
|
|
self.factor_t,
|
|
self.factor_s,
|
|
self.factor_s,
|
|
x.size(2),
|
|
x.size(3),
|
|
x.size(4),
|
|
)
|
|
x = x.permute(0, 1, 5, 2, 6, 3, 7, 4).contiguous()
|
|
x = x.view(
|
|
x.size(0),
|
|
self.out_channels,
|
|
x.size(2) * self.factor_t,
|
|
x.size(4) * self.factor_s,
|
|
x.size(6) * self.factor_s,
|
|
)
|
|
|
|
_first_chunk = first_chunk.get() if first_chunk is not None else None
|
|
if _first_chunk:
|
|
x = x[:, :, self.factor_t - 1 :, :, :]
|
|
return x
|
|
|
|
|
|
class WanCausalConv3d(nn.Conv3d):
|
|
r"""
|
|
A custom 3D causal convolution layer with feature caching support.
|
|
|
|
This layer extends the standard Conv3D layer by ensuring causality in the time dimension and handling feature
|
|
caching for efficient inference.
|
|
"""
|
|
|
|
def __init__(
|
|
self,
|
|
in_channels: int,
|
|
out_channels: int,
|
|
kernel_size: int | tuple[int, int, int],
|
|
stride: int | tuple[int, int, int] = 1,
|
|
padding: int | tuple[int, int, int] = 0,
|
|
) -> None:
|
|
super().__init__(
|
|
in_channels=in_channels,
|
|
out_channels=out_channels,
|
|
kernel_size=kernel_size,
|
|
stride=stride,
|
|
padding=padding,
|
|
)
|
|
self.padding: tuple[int, int, int]
|
|
# Set up causal padding
|
|
self._padding: tuple[int, ...] = (
|
|
self.padding[2],
|
|
self.padding[2],
|
|
self.padding[1],
|
|
self.padding[1],
|
|
2 * self.padding[0],
|
|
0,
|
|
)
|
|
self.padding = (0, 0, 0)
|
|
|
|
def forward(self, x, cache_x=None):
|
|
padding = list(self._padding)
|
|
x = causal_conv3d_cat_pad(x, cache_x, padding)
|
|
x = (
|
|
x if current_platform.is_amp_supported() else x.to(self.weight.dtype)
|
|
) # casting needed if amp isn't supported
|
|
x = match_conv3d_input_format(x, self.weight)
|
|
return super().forward(x)
|
|
|
|
|
|
class WanRMS_norm(nn.Module):
|
|
r"""
|
|
A custom RMS normalization layer.
|
|
"""
|
|
|
|
def __init__(
|
|
self,
|
|
dim: int,
|
|
channel_first: bool = True,
|
|
images: bool = True,
|
|
bias: bool = False,
|
|
) -> None:
|
|
super().__init__()
|
|
broadcastable_dims = (1, 1, 1) if not images else (1, 1)
|
|
shape = (dim, *broadcastable_dims) if channel_first else (dim,)
|
|
|
|
self.channel_first = channel_first
|
|
self.scale = dim**0.5
|
|
self.gamma = nn.Parameter(torch.ones(shape))
|
|
self.bias = nn.Parameter(torch.zeros(shape)) if bias else 0.0
|
|
|
|
def forward(self, x):
|
|
return (
|
|
F.normalize(x, dim=(1 if self.channel_first else -1))
|
|
* self.scale
|
|
* self.gamma
|
|
+ self.bias
|
|
)
|
|
|
|
|
|
class WanUpsample(nn.Upsample):
|
|
r"""
|
|
Perform upsampling while ensuring the output tensor has the same data type as the input.
|
|
"""
|
|
|
|
def forward(self, x):
|
|
if current_platform.is_amp_supported():
|
|
return super().forward(x)
|
|
return super().forward(x.float()).type_as(x)
|
|
|
|
|
|
def resample_forward(self, x):
|
|
b, c, t, h, w = x.size()
|
|
first_frame = is_first_frame.get()
|
|
if first_frame:
|
|
assert t == 1
|
|
_feat_cache = feat_cache.get()
|
|
_feat_idx = feat_idx.get()
|
|
if self.mode == "upsample3d":
|
|
if _feat_cache is not None:
|
|
idx = _feat_idx
|
|
if _feat_cache[idx] is None:
|
|
_feat_cache[idx] = "Rep"
|
|
_feat_idx += 1
|
|
else:
|
|
cache_x = x[:, :, -CACHE_T:, :, :].clone()
|
|
if (
|
|
cache_x.shape[2] < 2
|
|
and _feat_cache[idx] is not None
|
|
and _feat_cache[idx] != "Rep"
|
|
):
|
|
# cache last frame of last two chunk
|
|
cache_x = torch.cat(
|
|
[
|
|
_feat_cache[idx][:, :, -1, :, :]
|
|
.unsqueeze(2)
|
|
.to(cache_x.device),
|
|
cache_x,
|
|
],
|
|
dim=2,
|
|
)
|
|
if (
|
|
cache_x.shape[2] < 2
|
|
and _feat_cache[idx] is not None
|
|
and _feat_cache[idx] == "Rep"
|
|
):
|
|
cache_x = torch.cat(
|
|
[torch.zeros_like(cache_x).to(cache_x.device), cache_x],
|
|
dim=2,
|
|
)
|
|
if _feat_cache[idx] == "Rep":
|
|
x = self.time_conv(x)
|
|
else:
|
|
x = self.time_conv(x, _feat_cache[idx])
|
|
_feat_cache[idx] = cache_x
|
|
_feat_idx += 1
|
|
|
|
x = x.reshape(b, 2, c, t, h, w)
|
|
x = torch.stack((x[:, 0, :, :, :, :], x[:, 1, :, :, :, :]), 3)
|
|
x = x.reshape(b, c, t * 2, h, w)
|
|
feat_cache.set(_feat_cache)
|
|
feat_idx.set(_feat_idx)
|
|
elif not first_frame and hasattr(self, "time_conv"):
|
|
x = self.time_conv(x)
|
|
x = x.reshape(b, 2, c, t, h, w)
|
|
x = torch.stack((x[:, 0, :, :, :, :], x[:, 1, :, :, :, :]), 3)
|
|
x = x.reshape(b, c, t * 2, h, w)
|
|
t = x.shape[2]
|
|
x = x.permute(0, 2, 1, 3, 4).reshape(b * t, c, h, w)
|
|
x = self.resample(x)
|
|
x = x.view(b, t, x.size(1), x.size(2), x.size(3)).permute(0, 2, 1, 3, 4)
|
|
|
|
_feat_cache = feat_cache.get()
|
|
_feat_idx = feat_idx.get()
|
|
if self.mode == "downsample3d":
|
|
if _feat_cache is not None:
|
|
idx = _feat_idx
|
|
if _feat_cache[idx] is None:
|
|
_feat_cache[idx] = x.clone()
|
|
_feat_idx += 1
|
|
else:
|
|
cache_x = x[:, :, -1:, :, :].clone()
|
|
x = self.time_conv(torch.cat([_feat_cache[idx][:, :, -1:, :, :], x], 2))
|
|
_feat_cache[idx] = cache_x
|
|
_feat_idx += 1
|
|
feat_cache.set(_feat_cache)
|
|
feat_idx.set(_feat_idx)
|
|
elif not first_frame and hasattr(self, "time_conv"):
|
|
x = self.time_conv(x)
|
|
return x
|
|
|
|
|
|
def residual_block_forward(self, x):
|
|
# Apply shortcut connection
|
|
h = self.conv_shortcut(x)
|
|
|
|
# First normalization and activation
|
|
x = self.norm1(x)
|
|
x = self.nonlinearity(x)
|
|
|
|
_feat_cache = feat_cache.get()
|
|
_feat_idx = feat_idx.get()
|
|
if _feat_cache is not None:
|
|
idx = _feat_idx
|
|
cache_x = x[:, :, -CACHE_T:, :, :].clone()
|
|
if cache_x.shape[2] < 2 and _feat_cache[idx] is not None:
|
|
cache_x = torch.cat(
|
|
[
|
|
_feat_cache[idx][:, :, -1, :, :].unsqueeze(2).to(cache_x.device),
|
|
cache_x,
|
|
],
|
|
dim=2,
|
|
)
|
|
|
|
x = self.conv1(x, _feat_cache[idx])
|
|
_feat_cache[idx] = cache_x
|
|
_feat_idx += 1
|
|
feat_cache.set(_feat_cache)
|
|
feat_idx.set(_feat_idx)
|
|
else:
|
|
x = self.conv1(x)
|
|
|
|
# Second normalization and activation
|
|
x = self.norm2(x)
|
|
x = self.nonlinearity(x)
|
|
|
|
# Dropout
|
|
x = self.dropout(x)
|
|
|
|
_feat_cache = feat_cache.get()
|
|
_feat_idx = feat_idx.get()
|
|
if _feat_cache is not None:
|
|
idx = _feat_idx
|
|
cache_x = x[:, :, -CACHE_T:, :, :].clone()
|
|
if cache_x.shape[2] < 2 and _feat_cache[idx] is not None:
|
|
cache_x = torch.cat(
|
|
[
|
|
_feat_cache[idx][:, :, -1, :, :].unsqueeze(2).to(cache_x.device),
|
|
cache_x,
|
|
],
|
|
dim=2,
|
|
)
|
|
|
|
x = self.conv2(x, _feat_cache[idx])
|
|
_feat_cache[idx] = cache_x
|
|
_feat_idx += 1
|
|
feat_cache.set(_feat_cache)
|
|
feat_idx.set(_feat_idx)
|
|
else:
|
|
x = self.conv2(x)
|
|
|
|
# Add residual connection
|
|
return x + h
|
|
|
|
|
|
def attention_block_forward(self, x):
|
|
identity = x
|
|
batch_size, channels, num_frames, height, width = x.size()
|
|
x = x.permute(0, 2, 1, 3, 4).reshape(
|
|
batch_size * num_frames, channels, height, width
|
|
)
|
|
x = self.norm(x)
|
|
|
|
# compute query, key, value
|
|
qkv = self.to_qkv(x)
|
|
qkv = qkv.reshape(batch_size * num_frames, 1, channels * 3, -1)
|
|
qkv = qkv.permute(0, 1, 3, 2).contiguous()
|
|
q, k, v = qkv.chunk(3, dim=-1)
|
|
|
|
x = torch.nn.functional.scaled_dot_product_attention(q, k, v)
|
|
|
|
x = (
|
|
x.squeeze(1)
|
|
.permute(0, 2, 1)
|
|
.reshape(batch_size * num_frames, channels, height, width)
|
|
)
|
|
|
|
# output projection
|
|
x = self.proj(x)
|
|
|
|
# Reshape back: [(b*t), c, h, w] -> [b, c, t, h, w]
|
|
x = x.view(batch_size, num_frames, channels, height, width)
|
|
x = x.permute(0, 2, 1, 3, 4)
|
|
|
|
return x + identity
|
|
|
|
|
|
def mid_block_forward(self, x):
|
|
# First residual block
|
|
x = self.resnets[0](x)
|
|
|
|
# Process through attention and residual blocks
|
|
for attn, resnet in zip(self.attentions, self.resnets[1:], strict=True):
|
|
if attn is not None:
|
|
x = attn(x)
|
|
|
|
x = resnet(x)
|
|
|
|
return x
|
|
|
|
|
|
def residual_down_block_forward(self, x):
|
|
x_copy = x
|
|
for resnet in self.resnets:
|
|
x = resnet(x)
|
|
if self.downsampler is not None:
|
|
x = self.downsampler(x)
|
|
|
|
return x + self.avg_shortcut(x_copy)
|
|
|
|
|
|
def residual_up_block_forward(self, x):
|
|
if self.avg_shortcut is not None:
|
|
x_copy = x
|
|
|
|
for resnet in self.resnets:
|
|
x = resnet(x)
|
|
|
|
if self.upsampler is not None:
|
|
x = self.upsampler(x)
|
|
|
|
if self.avg_shortcut is not None:
|
|
x = x + self.avg_shortcut(x_copy)
|
|
|
|
return x
|
|
|
|
|
|
def up_block_forward(self, x):
|
|
for resnet in self.resnets:
|
|
x = resnet(x)
|
|
|
|
if self.upsamplers is not None:
|
|
x = self.upsamplers[0](x)
|
|
return x
|
|
|
|
|
|
def split_for_parallel_encode(
|
|
x: torch.Tensor, downsample_count: int, world_size: int, rank: int
|
|
):
|
|
orig_height = x.shape[-2]
|
|
expected_height = orig_height // (2**downsample_count)
|
|
factor = world_size * (2**downsample_count)
|
|
pad_h = (factor - orig_height % factor) % factor
|
|
if pad_h:
|
|
x = F.pad(x, (0, 0, 0, pad_h, 0, 0))
|
|
expected_local_height = (orig_height + pad_h) // (2**downsample_count) // world_size
|
|
x = torch.chunk(x, world_size, dim=-2)[rank]
|
|
return x, expected_height, expected_local_height
|
|
|
|
|
|
def ensure_local_height(x: torch.Tensor, expected_local_height: int | None):
|
|
if expected_local_height is None:
|
|
return x
|
|
if x.shape[-2] < expected_local_height:
|
|
pad = expected_local_height - x.shape[-2]
|
|
return F.pad(x, (0, 0, 0, pad, 0, 0))
|
|
if x.shape[-2] > expected_local_height:
|
|
return x[..., :expected_local_height, :].contiguous()
|
|
return x
|
|
|
|
|
|
@contextmanager
|
|
def forward_context(
|
|
first_frame_arg=False, feat_cache_arg=None, feat_idx_arg=None, first_chunk_arg=None
|
|
):
|
|
is_first_frame_token = is_first_frame.set(first_frame_arg)
|
|
feat_cache_token = feat_cache.set(feat_cache_arg)
|
|
feat_idx_token = feat_idx.set(feat_idx_arg)
|
|
first_chunk_token = first_chunk.set(first_chunk_arg)
|
|
try:
|
|
yield
|
|
finally:
|
|
is_first_frame.reset(is_first_frame_token)
|
|
feat_cache.reset(feat_cache_token)
|
|
feat_idx.reset(feat_idx_token)
|
|
first_chunk.reset(first_chunk_token)
|
|
|
|
|
|
class WanResample(nn.Module):
|
|
r"""
|
|
A custom resampling module for 2D and 3D data.
|
|
|
|
Args:
|
|
dim (int): The number of input/output channels.
|
|
mode (str): The resampling mode. Must be one of:
|
|
- 'none': No resampling (identity operation).
|
|
- 'upsample2d': 2D upsampling with nearest-exact interpolation and convolution.
|
|
- 'upsample3d': 3D upsampling with nearest-exact interpolation, convolution, and causal 3D convolution.
|
|
- 'downsample2d': 2D downsampling with zero-padding and convolution.
|
|
- 'downsample3d': 3D downsampling with zero-padding, convolution, and causal 3D convolution.
|
|
"""
|
|
|
|
def __init__(
|
|
self,
|
|
dim: int,
|
|
mode: str,
|
|
upsample_out_dim: int = None,
|
|
*,
|
|
conv2d_cls=nn.Conv2d,
|
|
zero_pad2d_cls=nn.ZeroPad2d,
|
|
spatial_parallel: bool = False,
|
|
) -> None:
|
|
super().__init__()
|
|
self.dim = dim
|
|
self.mode = mode
|
|
|
|
# default to dim //2
|
|
if upsample_out_dim is None:
|
|
upsample_out_dim = dim // 2
|
|
|
|
# layers
|
|
if mode == "upsample2d":
|
|
self.resample = nn.Sequential(
|
|
WanUpsample(scale_factor=(2.0, 2.0), mode="nearest-exact"),
|
|
conv2d_cls(dim, upsample_out_dim, 3, padding=1),
|
|
)
|
|
elif mode == "upsample3d":
|
|
self.resample = nn.Sequential(
|
|
WanUpsample(scale_factor=(2.0, 2.0), mode="nearest-exact"),
|
|
conv2d_cls(dim, upsample_out_dim, 3, padding=1),
|
|
)
|
|
self.time_conv = WanCausalConv3d(dim, dim * 2, (3, 1, 1), padding=(1, 0, 0))
|
|
|
|
elif mode == "downsample2d":
|
|
if spatial_parallel:
|
|
self.resample = nn.Sequential(
|
|
zero_pad2d_cls((0, 1, 0, 0)),
|
|
conv2d_cls(dim, dim, 3, stride=(2, 2), height_padding=(0, 1)),
|
|
)
|
|
else:
|
|
self.resample = nn.Sequential(
|
|
zero_pad2d_cls((0, 1, 0, 1)),
|
|
conv2d_cls(dim, dim, 3, stride=(2, 2)),
|
|
)
|
|
elif mode == "downsample3d":
|
|
if spatial_parallel:
|
|
self.resample = nn.Sequential(
|
|
zero_pad2d_cls((0, 1, 0, 0)),
|
|
conv2d_cls(dim, dim, 3, stride=(2, 2), height_padding=(0, 1)),
|
|
)
|
|
else:
|
|
self.resample = nn.Sequential(
|
|
zero_pad2d_cls((0, 1, 0, 1)),
|
|
conv2d_cls(dim, dim, 3, stride=(2, 2)),
|
|
)
|
|
self.time_conv = WanCausalConv3d(
|
|
dim, dim, (3, 1, 1), stride=(2, 1, 1), padding=(0, 0, 0)
|
|
)
|
|
|
|
else:
|
|
self.resample = nn.Identity()
|
|
|
|
def forward(self, x):
|
|
return resample_forward(self, x)
|
|
|
|
|
|
class WanResidualBlock(nn.Module):
|
|
r"""
|
|
A custom residual block module.
|
|
|
|
Args:
|
|
in_dim (int): Number of input channels.
|
|
out_dim (int): Number of output channels.
|
|
dropout (float, optional): Dropout rate for the dropout layer. Default is 0.0.
|
|
non_linearity (str, optional): Type of non-linearity to use. Default is "silu".
|
|
"""
|
|
|
|
def __init__(
|
|
self,
|
|
in_dim: int,
|
|
out_dim: int,
|
|
dropout: float = 0.0,
|
|
non_linearity: str = "silu",
|
|
*,
|
|
causal_conv3d_cls=WanCausalConv3d,
|
|
shortcut_conv3d_cls=WanCausalConv3d,
|
|
) -> None:
|
|
super().__init__()
|
|
self.in_dim = in_dim
|
|
self.out_dim = out_dim
|
|
self.nonlinearity = get_act_fn(non_linearity)
|
|
|
|
# layers
|
|
self.norm1 = WanRMS_norm(in_dim, images=False)
|
|
self.conv1 = causal_conv3d_cls(in_dim, out_dim, 3, padding=1)
|
|
self.norm2 = WanRMS_norm(out_dim, images=False)
|
|
self.dropout = nn.Dropout(dropout)
|
|
self.conv2 = causal_conv3d_cls(out_dim, out_dim, 3, padding=1)
|
|
self.conv_shortcut = (
|
|
shortcut_conv3d_cls(in_dim, out_dim, 1)
|
|
if in_dim != out_dim
|
|
else nn.Identity()
|
|
)
|
|
|
|
def forward(self, x):
|
|
return residual_block_forward(self, x)
|
|
|
|
|
|
class WanAttentionBlock(nn.Module):
|
|
r"""
|
|
Causal self-attention with a single head.
|
|
|
|
Args:
|
|
dim (int): The number of channels in the input tensor.
|
|
"""
|
|
|
|
def __init__(self, dim, *, spatial_parallel: bool = False) -> None:
|
|
super().__init__()
|
|
self.dim = dim
|
|
self.world_size = get_decode_parallel_world_size() if spatial_parallel else 1
|
|
|
|
# layers
|
|
self.norm = WanRMS_norm(dim)
|
|
self.to_qkv = nn.Conv2d(dim, dim * 3, 1)
|
|
self.proj = nn.Conv2d(dim, dim, 1)
|
|
|
|
def forward(self, x):
|
|
if self.world_size > 1:
|
|
x = gather_height_for_global_op(x).contiguous()
|
|
x = attention_block_forward(self, x)
|
|
if self.world_size > 1:
|
|
x = chunk_height_for_parallel_decode(x)
|
|
return x
|
|
|
|
|
|
class WanMidBlock(nn.Module):
|
|
"""
|
|
Middle block for WanVAE encoder and decoder.
|
|
|
|
Args:
|
|
dim (int): Number of input/output channels.
|
|
dropout (float): Dropout rate.
|
|
non_linearity (str): Type of non-linearity to use.
|
|
"""
|
|
|
|
def __init__(
|
|
self,
|
|
dim: int,
|
|
dropout: float = 0.0,
|
|
non_linearity: str = "silu",
|
|
num_layers: int = 1,
|
|
*,
|
|
residual_block_cls=WanResidualBlock,
|
|
attention_block_cls=WanAttentionBlock,
|
|
):
|
|
super().__init__()
|
|
self.dim = dim
|
|
|
|
# Create the components
|
|
resnets = [residual_block_cls(dim, dim, dropout, non_linearity)]
|
|
attentions = []
|
|
for _ in range(num_layers):
|
|
attentions.append(attention_block_cls(dim))
|
|
resnets.append(residual_block_cls(dim, dim, dropout, non_linearity))
|
|
self.attentions = nn.ModuleList(attentions)
|
|
self.resnets = nn.ModuleList(resnets)
|
|
|
|
self.gradient_checkpointing = False
|
|
|
|
def forward(self, x):
|
|
return mid_block_forward(self, x)
|
|
|
|
|
|
class WanResidualDownBlock(nn.Module):
|
|
|
|
def __init__(
|
|
self,
|
|
in_dim,
|
|
out_dim,
|
|
dropout,
|
|
num_res_blocks,
|
|
temperal_downsample=False,
|
|
down_flag=False,
|
|
*,
|
|
residual_block_cls=WanResidualBlock,
|
|
resample_cls=WanResample,
|
|
):
|
|
super().__init__()
|
|
|
|
# Shortcut path with downsample
|
|
self.avg_shortcut = AvgDown3D(
|
|
in_dim,
|
|
out_dim,
|
|
factor_t=2 if temperal_downsample else 1,
|
|
factor_s=2 if down_flag else 1,
|
|
)
|
|
|
|
# Main path with residual blocks and downsample
|
|
resnets = []
|
|
for _ in range(num_res_blocks):
|
|
resnets.append(residual_block_cls(in_dim, out_dim, dropout))
|
|
in_dim = out_dim
|
|
self.resnets = nn.ModuleList(resnets)
|
|
|
|
# Add the final downsample block
|
|
if down_flag:
|
|
mode = "downsample3d" if temperal_downsample else "downsample2d"
|
|
self.downsampler = resample_cls(out_dim, mode=mode)
|
|
else:
|
|
self.downsampler = None
|
|
|
|
def forward(self, x):
|
|
return residual_down_block_forward(self, x)
|
|
|
|
|
|
class WanDistResample(WanResample):
|
|
def __init__(self, dim: int, mode: str, upsample_out_dim: int = None) -> None:
|
|
super().__init__(
|
|
dim,
|
|
mode,
|
|
upsample_out_dim=upsample_out_dim,
|
|
conv2d_cls=SpatialParallelConv2d,
|
|
zero_pad2d_cls=SpatialParallelZeroPad2d,
|
|
spatial_parallel=True,
|
|
)
|
|
|
|
|
|
class WanDistResidualBlock(WanResidualBlock):
|
|
def __init__(
|
|
self,
|
|
in_dim: int,
|
|
out_dim: int,
|
|
dropout: float = 0.0,
|
|
non_linearity: str = "silu",
|
|
) -> None:
|
|
super().__init__(
|
|
in_dim,
|
|
out_dim,
|
|
dropout,
|
|
non_linearity,
|
|
causal_conv3d_cls=SpatialParallelCausalConv3d,
|
|
)
|
|
|
|
|
|
class WanDistAttentionBlock(WanAttentionBlock):
|
|
def __init__(self, dim) -> None:
|
|
super().__init__(dim, spatial_parallel=True)
|
|
|
|
|
|
class WanDistMidBlock(WanMidBlock):
|
|
def __init__(
|
|
self,
|
|
dim: int,
|
|
dropout: float = 0.0,
|
|
non_linearity: str = "silu",
|
|
num_layers: int = 1,
|
|
):
|
|
super().__init__(
|
|
dim,
|
|
dropout,
|
|
non_linearity,
|
|
num_layers=num_layers,
|
|
residual_block_cls=WanDistResidualBlock,
|
|
attention_block_cls=WanDistAttentionBlock,
|
|
)
|
|
|
|
|
|
class WanDistResidualDownBlock(WanResidualDownBlock):
|
|
def __init__(
|
|
self,
|
|
in_dim,
|
|
out_dim,
|
|
dropout,
|
|
num_res_blocks,
|
|
temperal_downsample=False,
|
|
down_flag=False,
|
|
):
|
|
super().__init__(
|
|
in_dim,
|
|
out_dim,
|
|
dropout,
|
|
num_res_blocks,
|
|
temperal_downsample=temperal_downsample,
|
|
down_flag=down_flag,
|
|
residual_block_cls=WanDistResidualBlock,
|
|
resample_cls=WanDistResample,
|
|
)
|
|
|
|
|
|
class WanEncoder3d(nn.Module):
|
|
r"""
|
|
A 3D encoder module.
|
|
|
|
Args:
|
|
dim (int): The base number of channels in the first layer.
|
|
z_dim (int): The dimensionality of the latent space.
|
|
dim_mult (list of int): Multipliers for the number of channels in each block.
|
|
num_res_blocks (int): Number of residual blocks in each block.
|
|
attn_scales (list of float): Scales at which to apply attention mechanisms.
|
|
temperal_downsample (list of bool): Whether to downsample temporally in each block.
|
|
dropout (float): Dropout rate for the dropout layers.
|
|
non_linearity (str): Type of non-linearity to use.
|
|
"""
|
|
|
|
def __init__(
|
|
self,
|
|
in_channels: int = 3,
|
|
dim=128,
|
|
z_dim=4,
|
|
dim_mult=(1, 2, 4, 4),
|
|
num_res_blocks=2,
|
|
attn_scales=(),
|
|
temperal_downsample=(True, True, False),
|
|
dropout=0.0,
|
|
non_linearity: str = "silu",
|
|
is_residual: bool = False, # wan 2.2 vae use a residual downblock
|
|
use_parallel_encode: bool = False,
|
|
):
|
|
super().__init__()
|
|
self.dim = dim
|
|
self.z_dim = z_dim
|
|
dim_mult = list(dim_mult)
|
|
self.dim_mult = dim_mult
|
|
self.num_res_blocks = num_res_blocks
|
|
self.attn_scales = list(attn_scales)
|
|
self.temperal_downsample = list(temperal_downsample)
|
|
self.nonlinearity = get_act_fn(non_linearity)
|
|
self.use_parallel_encode = use_parallel_encode
|
|
self.downsample_count = max(len(dim_mult) - 1, 0)
|
|
|
|
# dimensions
|
|
dims = [dim * u for u in [1] + dim_mult]
|
|
scale = 1.0
|
|
|
|
world_size = 1
|
|
if dist.is_initialized():
|
|
world_size = get_sp_world_size()
|
|
|
|
if use_parallel_encode and world_size > 1:
|
|
CausalConv3d = SpatialParallelCausalConv3d
|
|
ResidualDownBlock = WanDistResidualDownBlock
|
|
ResidualBlock = WanDistResidualBlock
|
|
AttentionBlock = WanDistAttentionBlock
|
|
Resample = WanDistResample
|
|
MidBlock = WanDistMidBlock
|
|
else:
|
|
CausalConv3d = WanCausalConv3d
|
|
ResidualDownBlock = WanResidualDownBlock
|
|
ResidualBlock = WanResidualBlock
|
|
AttentionBlock = WanAttentionBlock
|
|
Resample = WanResample
|
|
MidBlock = WanMidBlock
|
|
|
|
# init block
|
|
self.conv_in = CausalConv3d(in_channels, dims[0], 3, padding=1)
|
|
|
|
# downsample blocks
|
|
self.down_blocks = nn.ModuleList([])
|
|
for i, (in_dim, out_dim) in enumerate(zip(dims[:-1], dims[1:], strict=True)):
|
|
# residual (+attention) blocks
|
|
if is_residual:
|
|
self.down_blocks.append(
|
|
ResidualDownBlock(
|
|
in_dim,
|
|
out_dim,
|
|
dropout,
|
|
num_res_blocks,
|
|
temperal_downsample=(
|
|
temperal_downsample[i] if i != len(dim_mult) - 1 else False
|
|
),
|
|
down_flag=i != len(dim_mult) - 1,
|
|
)
|
|
)
|
|
else:
|
|
for _ in range(num_res_blocks):
|
|
self.down_blocks.append(ResidualBlock(in_dim, out_dim, dropout))
|
|
if scale in attn_scales:
|
|
self.down_blocks.append(AttentionBlock(out_dim))
|
|
in_dim = out_dim
|
|
|
|
# downsample block
|
|
if i != len(dim_mult) - 1:
|
|
mode = "downsample3d" if temperal_downsample[i] else "downsample2d"
|
|
self.down_blocks.append(Resample(out_dim, mode=mode))
|
|
scale /= 2.0
|
|
|
|
# middle blocks
|
|
self.mid_block = MidBlock(out_dim, dropout, non_linearity, num_layers=1)
|
|
|
|
# output blocks
|
|
self.norm_out = WanRMS_norm(out_dim, images=False)
|
|
self.conv_out = CausalConv3d(out_dim, z_dim, 3, padding=1)
|
|
|
|
self.gradient_checkpointing = False
|
|
self.world_size = 1
|
|
self.rank = 0
|
|
if dist.is_initialized():
|
|
self.world_size = get_sp_world_size()
|
|
self.rank = get_sp_parallel_rank()
|
|
|
|
def forward(self, x):
|
|
expected_local_height = None
|
|
expected_height = None
|
|
if self.use_parallel_encode and self.world_size > 1:
|
|
x, expected_height, expected_local_height = split_for_parallel_encode(
|
|
x, self.downsample_count, self.world_size, self.rank
|
|
)
|
|
|
|
_feat_cache = feat_cache.get()
|
|
_feat_idx = feat_idx.get()
|
|
if _feat_cache is not None:
|
|
idx = _feat_idx
|
|
cache_x = x[:, :, -CACHE_T:, :, :].clone()
|
|
if cache_x.shape[2] < 2 and _feat_cache[idx] is not None:
|
|
# cache last frame of last two chunk
|
|
cache_x = torch.cat(
|
|
[
|
|
_feat_cache[idx][:, :, -1, :, :]
|
|
.unsqueeze(2)
|
|
.to(cache_x.device),
|
|
cache_x,
|
|
],
|
|
dim=2,
|
|
)
|
|
x = self.conv_in(x, _feat_cache[idx])
|
|
_feat_cache[idx] = cache_x
|
|
_feat_idx += 1
|
|
feat_cache.set(_feat_cache)
|
|
feat_idx.set(_feat_idx)
|
|
else:
|
|
x = self.conv_in(x)
|
|
|
|
## downsamples
|
|
for layer in self.down_blocks:
|
|
x = layer(x)
|
|
|
|
## middle
|
|
if self.use_parallel_encode and self.world_size > 1:
|
|
x = ensure_local_height(x, expected_local_height)
|
|
x = self.mid_block(x)
|
|
|
|
## head
|
|
x = self.norm_out(x)
|
|
x = self.nonlinearity(x)
|
|
|
|
_feat_cache = feat_cache.get()
|
|
_feat_idx = feat_idx.get()
|
|
if _feat_cache is not None:
|
|
idx = _feat_idx
|
|
cache_x = x[:, :, -CACHE_T:, :, :].clone()
|
|
if cache_x.shape[2] < 2 and _feat_cache[idx] is not None:
|
|
# cache last frame of last two chunk
|
|
cache_x = torch.cat(
|
|
[
|
|
_feat_cache[idx][:, :, -1, :, :]
|
|
.unsqueeze(2)
|
|
.to(cache_x.device),
|
|
cache_x,
|
|
],
|
|
dim=2,
|
|
)
|
|
x = self.conv_out(x, _feat_cache[idx])
|
|
_feat_cache[idx] = cache_x
|
|
_feat_idx += 1
|
|
feat_cache.set(_feat_cache)
|
|
feat_idx.set(_feat_idx)
|
|
else:
|
|
x = self.conv_out(x)
|
|
|
|
if self.use_parallel_encode and self.world_size > 1:
|
|
x = gather_and_trim_height(x, expected_height)
|
|
return x
|
|
|
|
|
|
# adapted from: https://github.com/huggingface/diffusers/blob/main/src/diffusers/models/autoencoders/autoencoder_kl_wan.py
|
|
class WanResidualUpBlock(nn.Module):
|
|
"""
|
|
A block that handles upsampling for the WanVAE decoder.
|
|
Args:
|
|
in_dim (int): Input dimension
|
|
out_dim (int): Output dimension
|
|
num_res_blocks (int): Number of residual blocks
|
|
dropout (float): Dropout rate
|
|
temperal_upsample (bool): Whether to upsample on temporal dimension
|
|
up_flag (bool): Whether to upsample or not
|
|
non_linearity (str): Type of non-linearity to use
|
|
"""
|
|
|
|
def __init__(
|
|
self,
|
|
in_dim: int,
|
|
out_dim: int,
|
|
num_res_blocks: int,
|
|
dropout: float = 0.0,
|
|
temperal_upsample: bool = False,
|
|
up_flag: bool = False,
|
|
non_linearity: str = "silu",
|
|
*,
|
|
residual_block_cls=WanResidualBlock,
|
|
resample_cls=WanResample,
|
|
):
|
|
super().__init__()
|
|
self.in_dim = in_dim
|
|
self.out_dim = out_dim
|
|
|
|
if up_flag:
|
|
self.avg_shortcut = DupUp3D(
|
|
in_dim,
|
|
out_dim,
|
|
factor_t=2 if temperal_upsample else 1,
|
|
factor_s=2,
|
|
)
|
|
else:
|
|
self.avg_shortcut = None
|
|
|
|
# create residual blocks
|
|
resnets = []
|
|
current_dim = in_dim
|
|
for _ in range(num_res_blocks + 1):
|
|
resnets.append(
|
|
residual_block_cls(current_dim, out_dim, dropout, non_linearity)
|
|
)
|
|
current_dim = out_dim
|
|
|
|
self.resnets = nn.ModuleList(resnets)
|
|
|
|
# Add upsampling layer if needed
|
|
if up_flag:
|
|
upsample_mode = "upsample3d" if temperal_upsample else "upsample2d"
|
|
self.upsampler = resample_cls(
|
|
out_dim, mode=upsample_mode, upsample_out_dim=out_dim
|
|
)
|
|
else:
|
|
self.upsampler = None
|
|
|
|
self.gradient_checkpointing = False
|
|
|
|
def forward(self, x):
|
|
return residual_up_block_forward(self, x)
|
|
|
|
|
|
class WanUpBlock(nn.Module):
|
|
"""
|
|
A block that handles upsampling for the WanVAE decoder.
|
|
|
|
Args:
|
|
in_dim (int): Input dimension
|
|
out_dim (int): Output dimension
|
|
num_res_blocks (int): Number of residual blocks
|
|
dropout (float): Dropout rate
|
|
upsample_mode (str, optional): Mode for upsampling ('upsample2d' or 'upsample3d')
|
|
non_linearity (str): Type of non-linearity to use
|
|
"""
|
|
|
|
def __init__(
|
|
self,
|
|
in_dim: int,
|
|
out_dim: int,
|
|
num_res_blocks: int,
|
|
dropout: float = 0.0,
|
|
upsample_mode: str | None = None,
|
|
non_linearity: str = "silu",
|
|
*,
|
|
residual_block_cls=WanResidualBlock,
|
|
resample_cls=WanResample,
|
|
):
|
|
super().__init__()
|
|
self.in_dim = in_dim
|
|
self.out_dim = out_dim
|
|
|
|
# Create layers list
|
|
resnets = []
|
|
# Add residual blocks and attention if needed
|
|
current_dim = in_dim
|
|
for _ in range(num_res_blocks + 1):
|
|
resnets.append(
|
|
residual_block_cls(current_dim, out_dim, dropout, non_linearity)
|
|
)
|
|
current_dim = out_dim
|
|
|
|
self.resnets = nn.ModuleList(resnets)
|
|
|
|
# Add upsampling layer if needed
|
|
self.upsamplers = None
|
|
if upsample_mode is not None:
|
|
self.upsamplers = nn.ModuleList([resample_cls(out_dim, mode=upsample_mode)])
|
|
|
|
self.gradient_checkpointing = False
|
|
|
|
def forward(self, x):
|
|
return up_block_forward(self, x)
|
|
|
|
|
|
class WanDistResidualUpBlock(WanResidualUpBlock):
|
|
def __init__(
|
|
self,
|
|
in_dim: int,
|
|
out_dim: int,
|
|
num_res_blocks: int,
|
|
dropout: float = 0.0,
|
|
temperal_upsample: bool = False,
|
|
up_flag: bool = False,
|
|
non_linearity: str = "silu",
|
|
):
|
|
super().__init__(
|
|
in_dim,
|
|
out_dim,
|
|
num_res_blocks,
|
|
dropout=dropout,
|
|
temperal_upsample=temperal_upsample,
|
|
up_flag=up_flag,
|
|
non_linearity=non_linearity,
|
|
residual_block_cls=WanDistResidualBlock,
|
|
resample_cls=WanDistResample,
|
|
)
|
|
|
|
|
|
class WanDistUpBlock(WanUpBlock):
|
|
def __init__(
|
|
self,
|
|
in_dim: int,
|
|
out_dim: int,
|
|
num_res_blocks: int,
|
|
dropout: float = 0.0,
|
|
upsample_mode: str | None = None,
|
|
non_linearity: str = "silu",
|
|
):
|
|
super().__init__(
|
|
in_dim,
|
|
out_dim,
|
|
num_res_blocks,
|
|
dropout=dropout,
|
|
upsample_mode=upsample_mode,
|
|
non_linearity=non_linearity,
|
|
residual_block_cls=WanDistResidualBlock,
|
|
resample_cls=WanDistResample,
|
|
)
|
|
|
|
|
|
class WanDecoder3d(nn.Module):
|
|
r"""
|
|
A 3D decoder module.
|
|
|
|
Args:
|
|
dim (int): The base number of channels in the first layer.
|
|
z_dim (int): The dimensionality of the latent space.
|
|
dim_mult (list of int): Multipliers for the number of channels in each block.
|
|
num_res_blocks (int): Number of residual blocks in each block.
|
|
attn_scales (list of float): Scales at which to apply attention mechanisms.
|
|
temperal_upsample (list of bool): Whether to upsample temporally in each block.
|
|
dropout (float): Dropout rate for the dropout layers.
|
|
non_linearity (str): Type of non-linearity to use.
|
|
"""
|
|
|
|
def __init__(
|
|
self,
|
|
dim=128,
|
|
z_dim=4,
|
|
dim_mult=(1, 2, 4, 4),
|
|
num_res_blocks=2,
|
|
attn_scales=(),
|
|
temperal_upsample=(False, True, True),
|
|
dropout=0.0,
|
|
non_linearity: str = "silu",
|
|
out_channels: int = 3,
|
|
is_residual: bool = False,
|
|
use_parallel_decode: bool = False,
|
|
):
|
|
super().__init__()
|
|
self.dim = dim
|
|
self.z_dim = z_dim
|
|
dim_mult = list(dim_mult)
|
|
self.dim_mult = dim_mult
|
|
self.num_res_blocks = num_res_blocks
|
|
self.attn_scales = list(attn_scales)
|
|
self.temperal_upsample = list(temperal_upsample)
|
|
|
|
self.nonlinearity = get_act_fn(non_linearity)
|
|
self.use_parallel_decode = use_parallel_decode
|
|
self.upsample_count = 0
|
|
|
|
# dimensions
|
|
dims = [dim * u for u in [dim_mult[-1]] + dim_mult[::-1]]
|
|
|
|
world_size = 1
|
|
if dist.is_initialized():
|
|
world_size = get_decode_parallel_world_size()
|
|
|
|
if use_parallel_decode and world_size > 1:
|
|
CausalConv3d = SpatialParallelCausalConv3d
|
|
MidBlock = WanDistMidBlock
|
|
ResidualUpBlock = WanDistResidualUpBlock
|
|
UpBlock = WanDistUpBlock
|
|
else:
|
|
CausalConv3d = WanCausalConv3d
|
|
MidBlock = WanMidBlock
|
|
ResidualUpBlock = WanResidualUpBlock
|
|
UpBlock = WanUpBlock
|
|
|
|
# init block
|
|
self.conv_in = CausalConv3d(z_dim, dims[0], 3, padding=1)
|
|
|
|
# middle blocks
|
|
self.mid_block = MidBlock(dims[0], dropout, non_linearity, num_layers=1)
|
|
|
|
# upsample blocks
|
|
self.upsample_count = 0
|
|
self.up_blocks = nn.ModuleList([])
|
|
for i, (in_dim, out_dim) in enumerate(zip(dims[:-1], dims[1:], strict=True)):
|
|
# residual (+attention) blocks
|
|
if i > 0 and not is_residual:
|
|
# wan vae 2.1
|
|
in_dim = in_dim // 2
|
|
|
|
# determine if we need upsampling
|
|
up_flag = i != len(dim_mult) - 1
|
|
# determine upsampling mode, if not upsampling, set to None
|
|
upsample_mode = None
|
|
if up_flag and temperal_upsample[i]:
|
|
upsample_mode = "upsample3d"
|
|
elif up_flag:
|
|
upsample_mode = "upsample2d"
|
|
|
|
# Create and add the upsampling block
|
|
if is_residual:
|
|
up_block = ResidualUpBlock(
|
|
in_dim=in_dim,
|
|
out_dim=out_dim,
|
|
num_res_blocks=num_res_blocks,
|
|
dropout=dropout,
|
|
temperal_upsample=temperal_upsample[i] if up_flag else False,
|
|
up_flag=up_flag,
|
|
non_linearity=non_linearity,
|
|
)
|
|
else:
|
|
up_block = UpBlock(
|
|
in_dim=in_dim,
|
|
out_dim=out_dim,
|
|
num_res_blocks=num_res_blocks,
|
|
dropout=dropout,
|
|
upsample_mode=upsample_mode,
|
|
non_linearity=non_linearity,
|
|
)
|
|
self.up_blocks.append(up_block)
|
|
if up_flag:
|
|
self.upsample_count += 1
|
|
|
|
# output blocks
|
|
self.norm_out = WanRMS_norm(out_dim, images=False)
|
|
self.conv_out = CausalConv3d(out_dim, out_channels, 3, padding=1)
|
|
|
|
self.gradient_checkpointing = False
|
|
self.world_size = 1
|
|
self.rank = 0
|
|
if dist.is_initialized():
|
|
self.world_size = get_decode_parallel_world_size()
|
|
self.rank = get_decode_parallel_rank()
|
|
|
|
def forward(self, x):
|
|
expected_height = None
|
|
if self.use_parallel_decode and self.world_size > 1:
|
|
x, expected_height = split_for_parallel_decode(
|
|
x, self.upsample_count, self.world_size, self.rank
|
|
)
|
|
|
|
## conv1
|
|
_feat_cache = feat_cache.get()
|
|
_feat_idx = feat_idx.get()
|
|
if _feat_cache is not None:
|
|
idx = _feat_idx
|
|
cache_x = x[:, :, -CACHE_T:, :, :].clone()
|
|
if cache_x.shape[2] < 2 and _feat_cache[idx] is not None:
|
|
# cache last frame of last two chunk
|
|
cache_x = torch.cat(
|
|
[
|
|
_feat_cache[idx][:, :, -1, :, :]
|
|
.unsqueeze(2)
|
|
.to(cache_x.device),
|
|
cache_x,
|
|
],
|
|
dim=2,
|
|
)
|
|
x = self.conv_in(x, _feat_cache[idx])
|
|
_feat_cache[idx] = cache_x
|
|
_feat_idx += 1
|
|
feat_cache.set(_feat_cache)
|
|
feat_idx.set(_feat_idx)
|
|
else:
|
|
x = self.conv_in(x)
|
|
|
|
## middle
|
|
x = self.mid_block(x)
|
|
|
|
## upsamples
|
|
for up_block in self.up_blocks:
|
|
x = up_block(x)
|
|
|
|
## head
|
|
x = self.norm_out(x)
|
|
x = self.nonlinearity(x)
|
|
_feat_cache = feat_cache.get()
|
|
_feat_idx = feat_idx.get()
|
|
if _feat_cache is not None:
|
|
idx = _feat_idx
|
|
cache_x = x[:, :, -CACHE_T:, :, :].clone()
|
|
if cache_x.shape[2] < 2 and _feat_cache[idx] is not None:
|
|
# cache last frame of last two chunk
|
|
cache_x = torch.cat(
|
|
[
|
|
_feat_cache[idx][:, :, -1, :, :]
|
|
.unsqueeze(2)
|
|
.to(cache_x.device),
|
|
cache_x,
|
|
],
|
|
dim=2,
|
|
)
|
|
x = self.conv_out(x, _feat_cache[idx])
|
|
_feat_cache[idx] = cache_x
|
|
_feat_idx += 1
|
|
feat_cache.set(_feat_cache)
|
|
feat_idx.set(_feat_idx)
|
|
else:
|
|
x = self.conv_out(x)
|
|
|
|
if self.use_parallel_decode and self.world_size > 1:
|
|
x = gather_and_trim_height(x, expected_height)
|
|
return x
|
|
|
|
|
|
def patchify(x, patch_size):
|
|
if patch_size == 1:
|
|
return x
|
|
|
|
if x.dim() == 4:
|
|
x = rearrange(x, "b c (h q) (w r) -> b (c r q) h w", q=patch_size, r=patch_size)
|
|
elif x.dim() == 5:
|
|
x = rearrange(
|
|
x,
|
|
"b c f (h q) (w r) -> b (c r q) f h w",
|
|
q=patch_size,
|
|
r=patch_size,
|
|
)
|
|
else:
|
|
raise ValueError(f"Invalid input shape: {x.shape}")
|
|
|
|
return x
|
|
|
|
|
|
def unpatchify(x, patch_size):
|
|
if patch_size == 1:
|
|
return x
|
|
|
|
if x.dim() == 4:
|
|
x = rearrange(x, "b (c r q) h w -> b c (h q) (w r)", q=patch_size, r=patch_size)
|
|
elif x.dim() == 5:
|
|
x = rearrange(
|
|
x,
|
|
"b (c r q) f h w -> b c f (h q) (w r)",
|
|
q=patch_size,
|
|
r=patch_size,
|
|
)
|
|
|
|
return x
|
|
|
|
|
|
class AutoencoderKLWan(ParallelTiledVAE):
|
|
r"""
|
|
A VAE model with KL loss for encoding videos into latents and decoding latent representations into videos.
|
|
Introduced in [Wan 2.1].
|
|
"""
|
|
|
|
_supports_gradient_checkpointing = False
|
|
|
|
def __init__(
|
|
self,
|
|
config: WanVAEConfig,
|
|
) -> None:
|
|
nn.Module.__init__(self)
|
|
ParallelTiledVAE.__init__(self, config)
|
|
|
|
self.z_dim = config.z_dim
|
|
self.temperal_downsample = list(config.temperal_downsample)
|
|
self.temperal_upsample = list(config.temperal_downsample)[::-1]
|
|
|
|
if config.decoder_base_dim is None:
|
|
decoder_base_dim = config.base_dim
|
|
else:
|
|
decoder_base_dim = config.decoder_base_dim
|
|
|
|
self.latents_mean = list(config.latents_mean)
|
|
self.latents_std = list(config.latents_std)
|
|
self.shift_factor = config.shift_factor
|
|
self.use_parallel_encode = getattr(config, "use_parallel_encode", False)
|
|
self.use_parallel_decode = getattr(config, "use_parallel_decode", False)
|
|
|
|
if config.load_encoder:
|
|
self.encoder = WanEncoder3d(
|
|
in_channels=config.in_channels,
|
|
dim=config.base_dim,
|
|
z_dim=self.z_dim * 2,
|
|
dim_mult=config.dim_mult,
|
|
num_res_blocks=config.num_res_blocks,
|
|
attn_scales=config.attn_scales,
|
|
temperal_downsample=self.temperal_downsample,
|
|
dropout=config.dropout,
|
|
is_residual=config.is_residual,
|
|
use_parallel_encode=self.use_parallel_encode,
|
|
)
|
|
self.quant_conv = WanCausalConv3d(self.z_dim * 2, self.z_dim * 2, 1)
|
|
self.post_quant_conv = WanCausalConv3d(self.z_dim, self.z_dim, 1)
|
|
|
|
if config.load_decoder:
|
|
self.decoder = WanDecoder3d(
|
|
dim=decoder_base_dim,
|
|
z_dim=self.z_dim,
|
|
dim_mult=config.dim_mult,
|
|
num_res_blocks=config.num_res_blocks,
|
|
attn_scales=config.attn_scales,
|
|
temperal_upsample=self.temperal_upsample,
|
|
dropout=config.dropout,
|
|
out_channels=config.out_channels,
|
|
is_residual=config.is_residual,
|
|
use_parallel_decode=should_use_spatial_shard_parallel_decode(config),
|
|
)
|
|
|
|
self.use_feature_cache = config.use_feature_cache
|
|
self._causal_decode_initialized = False
|
|
|
|
def _should_use_spatial_parallel_decode(self, z: torch.Tensor) -> bool:
|
|
return should_run_spatial_shard_parallel_decode(self.config, z)
|
|
|
|
def clear_cache(self) -> None:
|
|
|
|
def _count_conv3d(model) -> int:
|
|
count = 0
|
|
for m in model.modules():
|
|
if isinstance(m, (WanCausalConv3d, SpatialParallelCausalConv3d)):
|
|
count += 1
|
|
return count
|
|
|
|
if self.config.load_decoder:
|
|
self._conv_num = _count_conv3d(self.decoder)
|
|
self._conv_idx = 0
|
|
self._feat_map = [None] * self._conv_num
|
|
# cache encode
|
|
if self.config.load_encoder:
|
|
self._enc_conv_num = _count_conv3d(self.encoder)
|
|
self._enc_conv_idx = 0
|
|
self._enc_feat_map = [None] * self._enc_conv_num
|
|
|
|
def reset_causal_decode_state(self) -> None:
|
|
"""Reset decoder feature cache before a new causal video session."""
|
|
self._causal_decode_initialized = False
|
|
if self.use_feature_cache:
|
|
self.clear_cache()
|
|
|
|
def causal_decode(self, z: torch.Tensor) -> torch.Tensor:
|
|
"""Decode latents while preserving decoder feature cache across chunks."""
|
|
if not self.use_feature_cache:
|
|
return self.decode(z)
|
|
|
|
is_first_chunk = not self._causal_decode_initialized
|
|
if is_first_chunk:
|
|
self.clear_cache()
|
|
|
|
iter_ = z.shape[2]
|
|
x = self.post_quant_conv(z)
|
|
outs = []
|
|
spatial_context = (
|
|
nullcontext()
|
|
if self._should_use_spatial_parallel_decode(z)
|
|
else disable_spatial_parallel_decode()
|
|
)
|
|
with spatial_context:
|
|
with forward_context(
|
|
feat_cache_arg=self._feat_map, feat_idx_arg=self._conv_idx
|
|
):
|
|
for i in range(iter_):
|
|
feat_idx.set(0)
|
|
first_chunk.set(is_first_chunk and i == 0)
|
|
outs.append(self.decoder(x[:, :, i : i + 1, :, :]))
|
|
out = torch.cat(outs, 2)
|
|
|
|
if self.config.patch_size is not None:
|
|
out = unpatchify(out, patch_size=self.config.patch_size)
|
|
|
|
out = out.float()
|
|
out = torch.clamp(out, min=-1.0, max=1.0)
|
|
self._causal_decode_initialized = True
|
|
return out
|
|
|
|
def encode(self, x: torch.Tensor) -> torch.Tensor:
|
|
if self.use_feature_cache:
|
|
self.clear_cache()
|
|
if self.config.patch_size is not None:
|
|
x = patchify(x, patch_size=self.config.patch_size)
|
|
with forward_context(
|
|
feat_cache_arg=self._enc_feat_map, feat_idx_arg=self._enc_conv_idx
|
|
):
|
|
t = x.shape[2]
|
|
iter_ = 1 + (t - 1) // 4
|
|
for i in range(iter_):
|
|
feat_idx.set(0)
|
|
if i == 0:
|
|
out = self.encoder(x[:, :, :1, :, :])
|
|
else:
|
|
out_ = self.encoder(x[:, :, 1 + 4 * (i - 1) : 1 + 4 * i, :, :])
|
|
out = torch.cat([out, out_], 2)
|
|
enc = self.quant_conv(out)
|
|
mu, logvar = enc[:, : self.z_dim, :, :, :], enc[:, self.z_dim :, :, :, :]
|
|
enc = torch.cat([mu, logvar], dim=1)
|
|
enc = DiagonalGaussianDistribution(enc)
|
|
self.clear_cache()
|
|
else:
|
|
for block in self.encoder.down_blocks:
|
|
if isinstance(block, WanResample) and block.mode == "downsample3d":
|
|
_padding = list(block.time_conv._padding)
|
|
_padding[4] = 2
|
|
block.time_conv._padding = tuple(_padding)
|
|
enc = ParallelTiledVAE.encode(self, x)
|
|
|
|
return enc
|
|
|
|
def _encode(self, x: torch.Tensor, first_frame=False) -> torch.Tensor:
|
|
with forward_context(first_frame_arg=first_frame):
|
|
out = self.encoder(x)
|
|
enc = self.quant_conv(out)
|
|
mu, logvar = enc[:, : self.z_dim, :, :, :], enc[:, self.z_dim :, :, :, :]
|
|
enc = torch.cat([mu, logvar], dim=1)
|
|
return enc
|
|
|
|
def tiled_encode(self, x: torch.Tensor) -> torch.Tensor:
|
|
first_frame = x[:, :, 0, :, :].unsqueeze(2)
|
|
first_frame = self._encode(first_frame, first_frame=True)
|
|
|
|
enc = ParallelTiledVAE.tiled_encode(self, x)
|
|
enc = enc[:, :, 1:]
|
|
enc = torch.cat([first_frame, enc], dim=2)
|
|
return enc
|
|
|
|
def spatial_tiled_encode(self, x: torch.Tensor) -> torch.Tensor:
|
|
first_frame = x[:, :, 0, :, :].unsqueeze(2)
|
|
first_frame = self._encode(first_frame, first_frame=True)
|
|
|
|
enc = ParallelTiledVAE.spatial_tiled_encode(self, x)
|
|
enc = enc[:, :, 1:]
|
|
enc = torch.cat([first_frame, enc], dim=2)
|
|
return enc
|
|
|
|
def decode(self, z: torch.Tensor) -> torch.Tensor:
|
|
if self.use_feature_cache:
|
|
self.clear_cache()
|
|
iter_ = z.shape[2]
|
|
x = self.post_quant_conv(z)
|
|
spatial_context = (
|
|
nullcontext()
|
|
if self._should_use_spatial_parallel_decode(z)
|
|
else disable_spatial_parallel_decode()
|
|
)
|
|
with spatial_context:
|
|
with forward_context(
|
|
feat_cache_arg=self._feat_map, feat_idx_arg=self._conv_idx
|
|
):
|
|
out_chunks = []
|
|
for i in range(iter_):
|
|
feat_idx.set(0)
|
|
first_chunk.set(i == 0)
|
|
out_chunks.append(self.decoder(x[:, :, i : i + 1, :, :]))
|
|
out = (
|
|
torch.cat(out_chunks, 2)
|
|
if len(out_chunks) > 1
|
|
else out_chunks[0]
|
|
)
|
|
|
|
if self.config.patch_size is not None:
|
|
out = unpatchify(out, patch_size=self.config.patch_size)
|
|
|
|
out = out.float()
|
|
out.clamp_(min=-1.0, max=1.0)
|
|
self.clear_cache()
|
|
else:
|
|
out = ParallelTiledVAE.decode(self, z)
|
|
|
|
return out
|
|
|
|
def _decode(self, z: torch.Tensor, first_frame=False) -> torch.Tensor:
|
|
x = self.post_quant_conv(z)
|
|
spatial_context = (
|
|
nullcontext()
|
|
if self._should_use_spatial_parallel_decode(z)
|
|
else disable_spatial_parallel_decode()
|
|
)
|
|
with spatial_context:
|
|
with forward_context(first_frame_arg=first_frame):
|
|
out = self.decoder(x)
|
|
|
|
out = torch.clamp(out, min=-1.0, max=1.0)
|
|
|
|
return out
|
|
|
|
def tiled_decode(self, z: torch.Tensor) -> torch.Tensor:
|
|
self.blend_num_frames *= 2
|
|
dec = ParallelTiledVAE.tiled_decode(self, z)
|
|
start_frame_idx = self.temporal_compression_ratio - 1
|
|
dec = dec[:, :, start_frame_idx:]
|
|
return dec
|
|
|
|
def spatial_tiled_decode(self, z: torch.Tensor) -> torch.Tensor:
|
|
dec = ParallelTiledVAE.spatial_tiled_decode(self, z)
|
|
start_frame_idx = self.temporal_compression_ratio - 1
|
|
dec = dec[:, :, start_frame_idx:]
|
|
return dec
|
|
|
|
def parallel_tiled_decode(self, z: torch.FloatTensor) -> torch.FloatTensor:
|
|
self.blend_num_frames *= 2
|
|
dec = ParallelTiledVAE.parallel_tiled_decode(self, z)
|
|
start_frame_idx = self.temporal_compression_ratio - 1
|
|
dec = dec[:, :, start_frame_idx:]
|
|
return dec
|
|
|
|
def forward(
|
|
self,
|
|
sample: torch.Tensor,
|
|
sample_posterior: bool = False,
|
|
generator: torch.Generator | None = None,
|
|
) -> torch.Tensor:
|
|
"""
|
|
Args:
|
|
sample (`torch.Tensor`): Input sample.
|
|
return_dict (`bool`, *optional*, defaults to `True`):
|
|
Whether or not to return a [`DecoderOutput`] instead of a plain tuple.
|
|
"""
|
|
x = sample
|
|
posterior = self.encode(x).latent_dist
|
|
if sample_posterior:
|
|
z = posterior.sample(generator=generator)
|
|
else:
|
|
z = posterior.mode()
|
|
dec = self.decode(z)
|
|
return dec
|
|
|
|
|
|
EntryClass = AutoencoderKLWan
|