ai-modcon/prism/prism-data-pipeline
Claude Code and agent skill by ai-modcon/prism
- community
Checking that the SKILL.md file is still in the repository.
Build and validate PRISM's data pipeline. Use when converting data to WebDataset shards, staging shards to compute nodes, enabling sequence-length bucketing, loading multiple datasets, or validating/analyzing a dataset. Triggers: "webdataset", "shard the data", "shard_modality", "MultiWebDataset", "bucketing", "validate dataset", "partition_by / local_shards_dir", "why does loss converge suspiciously fast".
Install
npx vskill@latest install ai-modcon/prism/prism-data-pipelineSKILL.md
PRISM — Data Pipeline
PRISM trains on WebDataset shards. The flow is: raw data → shard → (optionally stage to node-local /tmp) → MultiWebDataset loader → (optional) length bucketing → collator. Before trusting any loss curve or throughput number, confirm the pipeline feeds what you think it does — see the installed ml-data-pipeline-correctness skill.
When to load which reference
| Topic | File | |
|---|---|---|
| Convert HF datasets / CALVIN to WebDataset shards | `references/webdataset-conversion.md` | |
Multi-dataset loading, partition_by, local-shards staging, bucketing | `references/loading-and-bucketing.md` | |
| Validate shards & analyze sequence lengths | `references/validation.md` |
Fast facts
- Sharding tools are login-node only (no GPU/MPI):
tools/shard_modality.py
(HF → WebDataset for time_series/graph), applications/vla/shard_calvin_vla.py (CALVIN VLA episodes → shards, whole-episode / Markov-safe).
- Core loader:
src/data/multi_webdataset.py→MultiWebDatasetplus
wrappers MultiWebDatasetWrapper, ModalityAwareWebDatasetWrapper, BucketedMultiWebDatasetWrapper. LocalShardDataset was deleted (PR #104) — local-shards now go through MultiWebDataset(local_shards_dir=..., partition_by="local").
- Bucketing → ~3× throughput on mixed-length data (
--use-bucketing). - Validate before you train:
tools/validate_webdataset.py <path> --check-images.
The three traps that have burned real runs
- `glob.glob()` hangs on dfuse/DAOS mounts. The code uses
os.listdir()+
manual .endswith(".tar") filtering on purpose (see comment in src/data/multi_webdataset.py ~line 573). If you add shard-discovery code, do the same — never glob.glob() a DAOS path.
- `WEBDATASET_LOCAL_PATH` leaks across sweep cells. In a multi-cell sweep,
one cell's staged image-shard path bled into non-image cells (mismatch=True), silently training text-only cells on image data. Fixed in PR #73, but the class of bug — a shared env var carrying data config between cells — is easy to reintroduce. If throughput or loss looks wrong in a sweep, check the effective shard path per cell.
- Sample-dict shape changed with PR #104. Local-shards path now yields
unpadded text and no `text_attention_mask`. Downstream code that assumed padded text / a mask must handle the new shape.
See also
- Deep reference: `docs/training/data.md` — datasets, WebDataset format,
bucketing internals, straggler analysis, multi-dataset mixing.
- prism-daos-storage (staging to DAOS),
prism-launching-jobs (--dataset-groups, --use-bucketing).
- Generic installed skill:
ml-data-pipeline-correctness.
Security
- Security scanPassed, 90 of 100Pattern checks on the skill's files.
- Model reviewPassed
Quality evaluation
- Task evaluationNot runNo evaluation yet. Run one in Skill Studio.
Source
- SKILL.md in the repositoryCheckingdocs/skills/prism-data-pipeline/SKILL.md
Popularity
- Repository stars
- 12
- Repository forks
- 1
- 7-day trend score
- 0
Stars and forks are for the whole GitHub repository, not this skill alone. Not refreshed yet.
Works with
Any agent vskill installs to: 56 targets in all. These 39 have a page on this site.
- Claude Code
- Cursor
- GitHub Copilot
- Windsurf
- Codex
- Gemini CLI
- Cline
- Amp
- Roo Code
- Goose
- Continue
- Kilo Code
- Junie
- Trae
- OpenHands
- Qwen Code
- AI Agent
- Tabnine Chat
- Sourcegraph Cody
- Amazon Q
- Firebase Genkit
- Sweep
- Devin
- Phind
- Mentat
- Claude Desktop
- Aider
- GPT Pilot
- Plandex
- bolt.new
- v0
- Replit Agent
- Anse
- TypingMind
- BetterChatGPT
- LibreChat
- Warp AI
- Pieces
- Fig AI
Embed badge
[](https://verified-skill.com/skills/ai-modcon/prism/prism-data-pipeline)