domino-flows

Coordinate end-to-end ML workflows as DAGs with typed tasks and automatic lineage.

Updated Aug 27, 2026
One-click install
npx skills add https://github.com/jvdomino/domino-data-lab-plugin --skill domino-flows
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: domino-flows
Source: https://github.com/jvdomino/domino-data-lab-plugin/tree/main/skills/flows
Command: npx skills add https://github.com/jvdomino/domino-data-lab-plugin --skill domino-flows

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Domino Flows provides structured orchestration for ML pipelines, letting teams define DAG-based workflows with typed inputs/outputs, ensuring reproducibility, lineage, and scalable execution across heterogeneous environments.

Core Features & Use Cases

  • DAG-based orchestration with typed interfaces and explicit data contracts.
  • Heterogeneous environments for per-task tooling and dependencies.
  • Automatic lineage tracking and reproducibility for audits and compliance.
  • Use cases include end-to-end ML pipelines, multi-stage training workflows, ETL-like orchestrations, and monitoring.

Quick Start

Start a minimal pipeline by wiring two tasks, preprocess and train, and execute the workflow with sample inputs.

Frequently Asked Questions about domino-flows

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I orchestrate reproducible ML pipelines with automatic lineage tracking?

You can orchestrate reproducible ML pipelines by combining typed tasks into DAGs, which automatically tracks data lineage and enforces explicit input/output contracts for audit-ready execution.

What is the best way to build multi-stage training workflows across heterogeneous environments?

Building multi-stage training workflows across heterogeneous environments is best handled by defining DAG-based pipelines that allow per-task tooling and dependencies while coordinating execution across compute resources.

How do I track data lineage and ensure reproducibility for ETL-like orchestration?

Tracking data lineage for ETL-like orchestration is achieved by enforcing typed interfaces and explicit data contracts within the DAG, ensuring all pipeline executions are reproducible for compliance audits.

Can I use Flyte for DAG-based orchestration and multi-stage ML pipeline monitoring?

Yes, Flyte supports DAG-based orchestration for multi-stage ML pipelines by applying typed tasks, automatic provenance tracking, and reproducible execution across heterogeneous compute resources.

How do I start a minimal ML pipeline for preprocessing and training data?

To start a minimal ML pipeline, wire two typed tasks together—preprocess and train—and execute the workflow with sample inputs to coordinate the end-to-end process.

Why do I need explicit input/output contracts for ML pipeline orchestration?

Explicit input/output contracts are needed for ML pipeline orchestration to enforce typed interfaces, guarantee automatic lineage tracking, and ensure reproducible execution across diverse compute environments.