Workflow Engine for Kubernetes

A distributed, fault-tolerant task queue

Apache Airflow - A platform to programmatically author, schedule, and monitor workflows

A reactive notebook for Python — run reproducible experiments, execute as a script, deploy as an app, and version with git.

HathorNetwork's fullnode core

Hamilton helps data scientists and engineers define testable, modular, self-documenting dataflows, that encode lineage and metadata. Runs and scales everywhere python does.

async DAG task scheduling in Rust (WIP)

Go Implementation of the Spacemesh protocol full node. 💾⏰💪

一个无任何第三方依赖的跨平台自定义编排执行步骤的API, 基于DAG实现了依赖步骤依次顺序执行、非依赖步骤并发执行的调度功能. 提供API远程操作方式，批量执行Shell、Powershell、Python等命令，轻松完成运行自动化运维脚本等常见管理任务，轮询进程、安装或卸载软件、更新应用程序以及安装补丁。

Rill Flow is a high-performance, scalable distributed workflow orchestration service

🚀 The Mixin TEE-BFT-DAG network reference implementation.

An experimental multi-tenant distributed system platform

🚀 JavaScript diagramming library that uses SVG and HTML for rendering.

Open data platform based on Kubernetes. Scaleph supports SeaTunnel、Flink and Doris backended by SeaTunnel on Flink engine、Flink Kubernetes Operator and Doris operator.

【A common used C++ DAG framework】 一个通用的、无三方依赖的、跨平台的、收录于awesome-cpp的、基于流图的并行计算框架。欢迎star & fork

A high performance Python graph library implemented in Rust.

automated data pipeline using beautiful soup, apache airflow and dvc data versioning

Lightweight function pipeline (DAG) creation: 📚 Less Bookkeeping, 🎯 More Doing

Iris is an extensible asynchronous header-only framework written in pure modern C++, including a M:N task scheduler (with coroutine support for C++ 20 optionally) and an advanced DAG-based task dispatcher.

A small library to orchestrate and visualize function calls using graph structure.