Awesome Pipeline

A curated list of awesome pipeline toolkits inspired by Awesome Sysadmin

Pipeline frameworks & libraries

• ActionChain - A workflow system for simple linear success/failure workflows.
• Adage - Small package to describe workflows that are not completely known at definition time.
• AiiDA - workflow manager with a strong focus on provenance, performance and extensibility.
• Airflow - Python-based workflow system created by AirBnb.
• Anduril - Component-based workflow framework for scientific data analysis.
• Antha - High-level language for biology.
• Argo Workflows - Container-native workflow engine for orchestrating parallel data processing, ML, or CI jobs on Kubernetes.
• Autosubmit - An open source Python experiment and workflow manager used to manage complex workflows on Cloud and HPC platforms.
• AWE - Workflow and resource management system with CWL support.
• Balsam - Python-based high throughput task and workflow engine.
• Bds - Scripting language for data pipelines.
• Beam - Unified programming model for batch and streaming data-parallel processing pipelines.
• BioMake - GNU-Make-like utility for managing builds and complex workflows.
• BioQueue - Explicit framework with web monitoring and resource estimation.
• Bioshake - Haskell DSL built on shake with strong typing and EDAM support.
• Bistro - Library to build and execute typed scientific workflows.
• Bpipe - Tool for running and managing bioinformatics pipelines.
• Briefly - Python Meta-programming Library for Job Flow Control.
• Burr - Python based lightweight graph (i.e. can do loops and conditional branching, and not just DAGs) orchestrator.
• Cluster Flow - Command-line tool which uses common cluster managers to run bioinformatics pipelines.
• Clusterjob - Automated reproducibility, and hassle-free submission of computational jobs to clusters.
• Cocoindex - ETL framework to build fresh index.
• Compi - Application framework for portable computational pipelines.
• Compss - Programming model for distributed infrastructures.
• Conan2 - Light-weight workflow management application.
• Consecution - A Python pipeline abstraction inspired by Apache Storm topologies.
• Cosmos - Python library for massively parallel workflows.
• Couler - Unified interface for constructing and managing workflows on different workflow engines, such as Argo Workflows, Tekton Pipelines, and Apache Airflow.
• Covalent - Workflow orchestration toolkit for high-performance and quantum computing research and development.
• Cromwell - Workflow Management System geared towards scientific workflows from the Broad Institute.
• Cuneiform - Advanced functional workflow language and framework, implemented in Erlang.
• Cylc - A workflow engine for cycling systems, originally developed for operational environmental forecasting.
• Dagobah - Simple DAG-based job scheduler in Python.
• Dagr - A scala based DSL and framework for writing and executing bioinformatics pipelines as Directed Acyclic Graphs.
• Dagster - Python-based API for defining DAGs that interfaces with popular workflow managers for building data applications.
• DataJoint - an open-source relational framework for scientific data pipelines.
• Dask - Dask is a flexible parallel computing library for analytics.
• Dbt - Framework for writing analytics workflows entirely in SQL. The T part of ETL, focuses on analytics engineering.
• Dockerflow - Workflow runner that uses Dataflow to run a series of tasks in Docker.
• Dotflow - Python library for creating pipelines and workflows easily.
• Drake - Robust DSL akin to Make, implemented in Clojure.
• Drake R package - Reproducibility and high-performance computing with an easy R-focused interface. Unrelated to Factual's Drake. Succeeded by Targets.
• Dray - An engine for managing the execution of container-based workflows.
• ecFlow - Workflow manager.
• eHive - System for creating and running pipelines on a distributed compute resource.
• Fission Workflows - A fast, lightweight workflow engine for serverless/FaaS functions.
• Flex - Language agnostic framework for building flexible data science pipelines (Python/Shell/Gnuplot).
• Flowr - Robust and efficient workflows using a simple language agnostic approach (R package).
• Gc3pie - Python libraries and tools for running applications on diverse Grids and clusters.
• Guix Workflow Language - A workflow management language extension for GNU Guix.
• Gwf - Make-like utility for submitting workflows via qsub.
• Hamilton - A python micro-framework for describing dataflows; runs anywhere python runs.
• Hera - Hera is an Argo Python SDK. Hera aims to make construction and submission of various Argo Project resources easy and accessible to everyone! Hera abstracts away low-level setup details while still maintaining a consistent vocabulary with Argo.
• HyperLoom - Platform for defining and executing workflow pipelines in large-scale distributed environments.
• HyperQueue - HPC-focused task scheduler that automatically assigns tasks to Slurm/PBS allocations and submits them for the user.
• Joblib - Set of tools to provide lightweight pipelining in Python.
• Jug - A task Based parallelization framework for Python.
• Kedro - Workflow development tool that helps you build data pipelines.
• Kestra - Open source data orchestration and scheduling platform with declarative syntax.
• Ketrew - Embedded DSL in the OCAML language alongside a client-server management application.
• Koheesio - Python framework for building efficient data pipelines.
• Kronos - Workflow assembler for cancer genome analytics and informatics.
• Kubeflow Pipelines - Framework for building and deploying portable, scalable machine learning workflows using Docker containers and Argo Workflows.
• Loom - Tool for running bioinformatics workflows locally or in the cloud.
• Longbow - Job proxying tool for biomolecular simulations.
• Luigi - Python module that helps you build complex pipelines of batch jobs.
• Maestro - YAML based HPC workflow execution tool.
• Makeflow - Workflow engine for executing large complex workflows on clusters.
• Makeit - Run R scripts if needed, based on last modified time.
• makepipe - An R package which provides a set of simple tools for transforming an existing workflow into a self-documenting pipeline with very minimal upfront costs.
• Mara - A lightweight, opinionated ETL framework, halfway between plain scripts and Apache Airflow.
• Mario - Scala library for defining data pipelines.
• Martian - A language and framework for developing and executing complex computational pipelines.
• MD Studio - Microservice based workflow engine.
• MetaFlow - Open-sourced framework from Netflix, for DAG generation for data scientists. Python and R API's.
• Mistral - Python based workflow engine by the Open Stack project.
• MLPipelineHolder - Lightweight Python framework for reproducible machine-learning experimentation in Jupyter notebooks.
• Moa - Lightweight workflows in bioinformatics.
• Nextflow - Flow-based computational toolkit for reproducible and scalable bioinformatics pipelines.
• nFlow - Embeddable JVM-based workflow engine with high availability, fault tolerance, and support for multiple databases. Additional libraries are provided for visualization and REST API.
• NiPype - Workflows and interfaces for neuroimaging packages.
• OpenGE - Accelerated framework for manipulating and interpreting high-throughput sequencing data.
• Pachyderm - Distributed and reproducible data pipelining and data management, built on the container ecosystem.
• Parsl - Productive parallel programming, for creating parallel programs composed of Python functions and external components.
• pdChemChain - Build pandas dataframe processing pipelines interactively in notebooks and save for command line resusage. Generally applicable but currently focuses on chemistry (RDKit).
• PipeFunc - Lightweight function pipeline (DAG) creation in pure Python for scientific workflows.
• PipEngine - Ruby based launcher for complex biological pipelines.
• Pinball - Python based workflow engine by Pinterest.
• Popper - YAML based container-native workflow engine supporting Docker, Singularity, Vagrant VMs with Docker daemon in VM, and local host.
• Porcupine - Haskell workflow tool to express and compose tasks (optionally cached) whose datasources and sinks are known ahead of time and rebindable, and which can expose arbitrary sets of parameters to the outside world.
• Prefect - Python based workflow engine powering Prefect.
• Pydra - Lightweight, DAG-based Python dataflow engine for reproducible and scalable scientific pipelines.
• PyFlow - Lightweight parallel task engine.
• pyperator - Simple push-based python workflow framework using asyncio, supporting recursive networks.
• pyppl - A python lightweight pipeline framework.
• pypyr - Automation task-runner for sequential steps defined in a pipeline yaml, with AWS and Slack plug-ins.
• pytask - A workflow management system that facilitates reproducible data analyses.
• Pwrake - Parallel workflow extension for Rake.
• Qdo - Lightweight high-throughput queuing system for workflows with many small tasks to perform.
• Qsubsec - Simple tokenised template system for SGE.
• Rabix - Python-based workflow toolkit based on the Common Workflow Language and Docker.
• Rain - Framework for large distributed task-based pipelines, written in Rust with Python API.
• Ray - Flexible, high-performance distributed Python execution framework.
• Redun - Yet another redundant workflow engine.
• Reflow - Language and runtime for distributed, incremental data processing in the cloud.
• Remake - Make-like declarative workflows in R.
• Renart - Local-first IDE for authoring and running SQL and Python data pipelines stored in Git.
• Rmake - Wrapper for the creation of Makefiles, enabling massive parallelization.
• Rubra - Pipeline system for bioinformatics workflows.
• Ruffus - Computation Pipeline library for Python.
• Ruigi - Pipeline tool for R, inspired by Luigi.
• Rhylthyme - Language and runner for real-time scheduling and logistics.
• Sake - Self-documenting build automation tool.
• SciLuigi - Helper library for writing flexible scientific workflows in Luigi.
• SciPipe - Library for writing Scientific Workflows in Go.
• Signac - Lightweight, but scalable framework for file-driven workflows to be run locally and on HPC systems.
• Scoop - Scalable Concurrent Operations in Python.
• Seqtools - Python library for lazy evaluation of pipelined transformations on indexable containers.
• SmartPipeline - A framework for rapid development of robust data pipelines following a simple design pattern.
• Snakemake - Tool for running and managing bioinformatics pipelines.
• Spiff - Based on the Workflow Patterns initiative and implemented in Python.
• Stolos - Directed Acyclic Graph task dependency scheduler that simplify distributed pipelines.
• Steppy - lightweight, open-source, Python 3 library for fast and reproducible experimentation. (This repository has been archived by the owner on Jun 22, 2022.)
• Stpipe - File processing pipelines as a Python library.
• StreamFlow - Container native workflow management system focused on hybrid workflows.
• StreamPipes - A self-service IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
• Sundial - Jobsystem on AWS ECS or AWS Batch managing dependencies and scheduling.
• Suro - Java-based distributed pipeline from Netflix.
• Swift - Fast easy parallel scripting - on multicores, clusters, clouds and supercomputers.
• TAF - R package to organize reproducible scientific workflows.
• Targets - Dynamic, function-oriented Make-like reproducible pipelines at scale in R.
• TaskGraph - A library to help manage complicated computational software pipelines consisting of long running individual tasks.
• Tibanna - Tool that helps you run genomic pipelines on Amazon cloud.
• Toil - Distributed pipeline workflow manager (mostly for genomics).
• Velda - Workflow compute layer that lets any job start instantly, scale across clouds, and avoid dependency drift by design.
• Yap - Extensible parallel framework, written in Python using OpenMPI libraries.
• Yapp - A C++ parallel pipeline library for stream processing.
• Wallaroo - Framework for streaming data applications and algorithms that react to real-time events.
• WESkit - An open source implementation of a Workflow Execution Service (WES). It tries to be GA4GH-compliant.
• WorldMake - Easy Collaborative Reproducible Computing.
• Zenaton - Workflow engine for orchestrating jobs, data and events across your applications and third party services.
• ZenML - Extensible open-source MLOps framework to create reproducible pipelines for data scientists.

Workflow platforms

• ActivePapers - Computational science made reproducible and publishable.
• Active Workflow - Polyglot workflows without leaving the comfort of your technology stack.
• Anvi’o - A community and framework centered around metagenomics, designed to facilitate reproducible exploration and visualization of data.
• Apache Iravata - Framework for executing and managing computational workflows on distributed computing resources.
• Arteria - Event-driven automation for sequencing centers. Initiates workflows based on events.
• Arvados - A container based workflow platform.
• Biokepler - Bioinformatics Scientific Workflow for Distributed Analysis of Large-Scale Biological Data. (inactive since 10/2019)
• Butler - Framework for running scientific workflows on public and academic clouds.
• Chipster - Open source platform for data analysis.
• Clubber - Cluster Load Balancer for Bioinformatics e-Resources.
• Digdag - Workflow manager designed for simplicity, extensibility and collaboration.
• Domino - User friendly and open source visual workflow management platform.
• Fireworks - Centralized workflow server for dynamic workflows of high-throughput computations.
• Flojoy - Open source visual Python scripting for test, measurement, and robotics control.
• Flowfile - Open-source local data platform with a visual pipeline builder and a Polars-compatible Python API.
• FlowHub - FlowHub is a new workflow cloud platform.
• Flyte - Container-native, type-safe workflow and pipelines platform for large scale processing and ML.
• Galaxy - Powerful workflow system which can be used on the command line or with the GUI.
• Geoweaver - In-browser tool for data processing workflows with high-performance server support, featuring code history and workflow orchestration.
• Kepler - Kepler scientific workflow application from University of California.
• KNIME Analytics Platform - General-purpose platform with many specialized domain extensions.
• Kubeflow - Toolkit for making deployments of machine learning workflows on Kubernetes simple, portable and scalable.
• omega|ml DataOps Platform - Data & model pipeline deployment for humans - integrated, scalable, extensible.
• OpenMOLE - Workflow Management System for exploration of models and parameter optimization.
• Ophidia - Data-analytics platform with declarative workflows of distributed operations.
• Orchest - An IDE for Data Science.
• Pegasus - Workflow Management System.
• Piper - Distributed workflow engine designed to be dead simple.
• Polyaxon - A platform for machine learning experimentation workflow.
• Reana - Platform for reusable research data analyses developed by CERN.
• Sushi - Supporting User for SHell script Integration.
• Taverna - Domain independent workflow system.
• Temporal - Highly scalable developer oriented Workflow as Code engine.
• Velda - Workflow compute layer that lets any job start instantly, scale across clouds, and avoid dependency drift by design.
• VisTrails - Scientific workflow and provenance management system.
• Watchdog - Workflow management system for the automated and distributed analysis of large-scale experimental data.
• Windmill - Developer platform and workflow engine to turn scripts into internal tools.
• Wings - Semantic workflow system utilizing Pegasus as execution system.
• Yabi - Online research environment for grid, HPC and cloud computing.

Workflow languages

• Common Workflow Language
• Cloudgene Workflow Language
• OpenMOLE DSL
• Workflow Description Language
• Pipelines

Workflow standardization initiatives

• Workflow 4 Ever Initiative
• Workflow 4 Ever workflow research object model
• Workflow Patterns Initiative
• Workflow Patterns Library
• ResearchObject.org

Workflow registries

• WorkflowHub - Workflows across research domains and languages
• Dockstore - Containers and workflows, in particular life sciences
• nf-core - Curated Nextflow workflows for life sciences
• Galaxy Workflow Library (IWC) - Curated Galaxy workflows

ETL & Data orchestration

• DataLad - git and git-annex based data version control system with lightweight provenance capture/re-execution support.
• DVC - Data version control system for ML project with lightweight pipeline support.
• lakeFS - Repeatable, atomic and versioned data lake on top of object storage.
• Nessie - Provides Git-like capability & version control for Iceberg Tables, Delta Lake Tables & SQL Views.
• DataScreenIQ - Real-time data quality screening API that returns PASS / WARN / BLOCK verdicts at the ingest boundary before data enters pipelines or warehouses in milliseconds.Python SDK available.

Literate programming (aka interactive notebooks)

• Beaker Notebook-style development environment.
• Binder - Turn a GitHub repo into a collection of interactive notebooks powered by Jupyter and Kubernetes
• IPython A rich architecture for interactive computing.
• Jupyter Language-agnostic notebook literate programming environment.
• Org Mode GNU Emacs major mode for computational notebooks, literate programming, and much more.
• Pathomx - Interactive data workflows built on Python.
• Polynote - A better notebook for Scala (and more). Built by Netflix.
• Ploomber - Consolidate your notebooks and scripts in a reproducible pipeline using a pipeline.yaml file
• R Notebooks - R Markdown notebook literate programming environment.
• RedPoint Notebooks - Web-native computational notebook for programmers supporting multiple languages, APIs and webooks.
• SoS - Readable, interactive, cross-platform and cross-language data science workflow system.
• Zeppelin - Web-based notebook that enables interactive data analytics.

Extract, transform, load (ETL)

• adbcBridge - Driver for ADBC, Apache Arrow's database connectivity API, that runs on top of any ODBC driver, so databases shipping ODBC but no Arrow driver (Db2, Informix, Vertica, Firebird, Ingres and more) return columnar Arrow batches and take bulk loads. One C library with Python, Rust, Go, Java and C# bindings; verified against 53 databases on Linux, 45 on macOS and 48 on Windows.
• Bruin - Data pipeline framework supporting SQL and Python in the same DAG. Built-in data quality assertions, cross-database lineage, and incremental processing. Targets data warehouses (BigQuery, Snowflake, Postgres, etc.).
• Cadence Distributed, scalable, durable, and highly available orchestration engine developed by Uber.
• Dataform - Dataform is a framework for managing SQL based operations in your data warehouse.
• Datanika - Self-hosted ELT platform combining dlt extract-and-load, dbt-core transforms and scheduling in one UI.
• Hevo - Hevo is a Fully Automated, No-code Data Pipeline Platform that supports 150+ ready-to-use integrations across Databases, SaaS Applications, Cloud Storage, SDKs, and Streaming Services.
• Hydra ETL - Declarative ETL engine where pipelines are YAML files validated before they run.
• Kiba ETL - A data processing & ETL framework for Ruby.
• LinkedPipes ETL - Linked Data publishing and consumption ETL tool.

• Omniload - Polyglot data loader based on dlt for ETL, warehousing and more. Copy data between any source and any destination. Supports 140+ source/destination adapters. Fast transformations based on Polars expressions.

• Pathway - Performant open-source Python ETL framework with Rust runtime, supporting 300+ data sources.
• Pentaho Kettle - A plataform that delivers poweful ETL capabilities, using a groundbreaking, metadata-driven approach.
• Substation - Substation is a cloud native data pipeline and transformation toolkit written in Go.
• DataRaven - Managed cloud object storage transfers for ingestion workflows.

Continuous Delivery workflows

• Argo - Get stuff done with container-native workflows for Kubernetes.
• CDS - A pipeline based Continuous Delivery Service written in Golang.

Build automation tools

• Bazel - Build software just as engineers do at Google.
• doit - Highly generalized task-management and automation in Python.
• Gradle - Unified cross platforms builds.
• Just - Command and recipe runner similar to Make, built in Rust.
• Make - The GNU Make build system.
• Prodmodel - Build system for data science pipelines.
• Scons - Python library focused on C/C++ builds.
• Shake - Define robust build systems akin to GNU Make using Haskell.

Automated workflow composition

• APE - A tool for the automated exploration of possible computational workflows based on semantic annotations.

Other projects

• HPC Grid Runner
• NiFi - Powerful and scalable directed graphs of data routing, transformation, and system mediation logic.
• noWorkflow - Supporting infrastructure to run scientific experiments without a scientific workflow management system, and still get things like provenance.
• Reprozip - Simplifies the process of creating reproducible experiments from command-line executions.

Related lists

• Awesome streaming - Curated list of awesome streaming frameworks, applications.
• Awesome ETL - Curated list of notable ETL (extract, transform, load) frameworks, libraries and software.
• Awesome workflow engines - Curated list of awesome open source workflow engines.
• Computational Data Analysis Workflow Systems