Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,6 @@
from cosmos_framework.data.imaginaire.webdataset.augmentors.augmentor import Augmentor
from cosmos_framework.utils import log

# COSMOS-RELEASE-END-IGNORE

# For the qwen captions, we have 3 variants: short, medium, long
# In addition, for synthetic data, we create prompt embeddings as well.
# There is quite a bit of entropy in the way prompt data is saved.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -486,9 +486,6 @@ def reset(self) -> None:
if self._fid_metric is not None:
self._fid_metric.reset()


# COSMOS-RELEASE-END-IGNORE

__all__ = [
"TokenizerMetric",
"PSNRMetric",
Expand Down
17 changes: 1 addition & 16 deletions cosmos_framework/model/vfm/omni_mot_model.py
Original file line number Diff line number Diff line change
Expand Up @@ -2432,6 +2432,7 @@ def _single_velocity_fn(tokens: list[list[int]], skip_text_tokens: bool):
# Peers needed CFG so we ran the uncond forward to keep
# FSDP allgather aligned; locally we still return cond.
return cond_v

v_pred = [u_i + guidance * (c_i - u_i) for c_i, u_i in zip(cond_v, uncond_v)]
if normalize_cfg:
v_pred = [
Expand All @@ -2450,22 +2451,6 @@ def _single_velocity_fn(tokens: list[list[int]], skip_text_tokens: bool):
# Same alignment story as above for the postprocess branch.
return cond_v

if not needs_cfg:
# This rank doesn't actually need CFG (guidance==1.0 or sigma
# outside guidance_interval). Return cond_v directly so the
# output is bit-identical to the original no-CFG path; the
# uncond_v forward was only run to keep the FSDP allgather
# sequence aligned with peers.
return cond_v

if not needs_cfg:
# This rank doesn't actually need CFG (guidance==1.0 or sigma
# outside guidance_interval). Return cond_v directly so the
# output is bit-identical to the original no-CFG path; the
# uncond_v forward was only run to keep the FSDP allgather
# sequence aligned with peers.
return cond_v

v_pred = [u_i + guidance * (c_i - u_i) for c_i, u_i in zip(cond_v, uncond_v)]

if normalize_cfg:
Expand Down