Skip to content

Phase 2: thread format version through clustering - #941

Open
kevinjzhang wants to merge 2 commits into
facebook:devfrom
kevinjzhang:export-D113974921
Open

Phase 2: thread format version through clustering#941
kevinjzhang wants to merge 2 commits into
facebook:devfrom
kevinjzhang:export-D113974921

Conversation

@kevinjzhang

Copy link
Copy Markdown
Contributor

Summary:
Threads the resolved target format version through the clustering trainer:

  • clusterSuccessors() now filters the clustering (concat) codecs by
    ZL_Compressor_Node_getMinVersion against the target version and throws
    FormatVersionUnsupportedError if none survive (so the orchestrator can fall
    clustering back to zstd), and builds its round-trip CCtx at the target version.
  • train_cluster() resolves the version from TrainParams and passes it through
    Trainer::getTrainedClusteringConfig into CompressionUtils, whose per-sample
    benchmark CCtx now targets that version instead of ZL_MAX_FORMAT_VERSION.

FormatVersionUnsupportedError moved to train_params.h (train_common) so it is
visible to every trainer and the orchestrator without a BUCK dependency cycle.

Reviewed By: terrelln

Differential Revision: D113974921

Summary:

Adds a shared training utility that filters candidate graphs by compressing caller-provided MultiInput samples at a target format version. Callers are responsible for supplying inputs that exercise the graph paths whose compatibility must be tested.

Also ensures format version is set inside managed compression base graph constructors.

Reviewed By: terrelln

Differential Revision: D114119859
Summary:
Threads the resolved target format version through the clustering trainer:

- clusterSuccessors() now filters the clustering (concat) codecs by
  ZL_Compressor_Node_getMinVersion against the target version and throws
  FormatVersionUnsupportedError if none survive (so the orchestrator can fall
  clustering back to zstd), and builds its round-trip CCtx at the target version.
- train_cluster() resolves the version from TrainParams and passes it through
  Trainer::getTrainedClusteringConfig into CompressionUtils, whose per-sample
  benchmark CCtx now targets that version instead of ZL_MAX_FORMAT_VERSION.

FormatVersionUnsupportedError moved to train_params.h (train_common) so it is
visible to every trainer and the orchestrator without a BUCK dependency cycle.

Reviewed By: terrelln

Differential Revision: D113974921
@meta-cla meta-cla Bot added the cla signed label Aug 7, 2026
@meta-codesync

meta-codesync Bot commented Aug 7, 2026

Copy link
Copy Markdown

@kevinjzhang has exported this pull request. If you are a Meta employee, you can view the originating Diff in D113974921.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant