[Bugfix] Fix IndexError in DistributedVaeExecutor when vae_patch_parallel_size < world_size (#3928)

Signed-off-by: QingZhou-YangHY <3868850350@qq.com>
This commit is contained in:
Huanyu Yang authored and GitHub committed 2026-05-29 03:17:34 -07:00
1 parent 67bb9b4a12
commit 3457758114
1 file changed
+1 -1
@@ -125,7 +125,7 @@ class DistributedVaeExecutor:
# 2. local decode
assigned = self._balance_tasks(tiletask_list, pp_size)
local_tasks = assigned[self.rank] if pp_size <= self.world_size else []
local_tasks = assigned[self.rank] if self.rank < pp_size else []
local_results = [(t.tile_id, operator.exec(t)) for t in local_tasks]
# 3. compute shape per rank