TelemodemTI/dagserver

Dag server based on quartz, allows to execute batch processes modeled as DAG (Direct Acyclic graph). Inspired by Apache Airflow and IBM Datastage

Language: JavaScript - Size: 66.9 MB - Last synced: about 4 hours ago - Pushed: about 5 hours ago - Stars: 5 - Forks: 0

Taraxa-project/taraxa-node

Taraxa blockchain full node implementation

Language: C++ - Size: 902 MB - Last synced: about 8 hours ago - Pushed: about 10 hours ago - Stars: 37 - Forks: 18

flowerfine/scaleph

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

Language: Java - Size: 20.3 MB - Last synced: about 8 hours ago - Pushed: about 10 hours ago - Stars: 334 - Forks: 96

sha1n/dagraph

Directed acyclic graph utility in TypeScript

Language: TypeScript - Size: 1.4 MB - Last synced: about 9 hours ago - Pushed: about 16 hours ago - Stars: 1 - Forks: 1

MyButifullyLife/vue-x6-flow

vue版流程图简易编辑器、简单易上手

Language: Vue - Size: 680 KB - Last synced: about 11 hours ago - Pushed: about 13 hours ago - Stars: 126 - Forks: 28

Qiskit/rustworkx

A high performance Python graph library implemented in Rust.

Language: Rust - Size: 22.2 MB - Last synced: about 16 hours ago - Pushed: about 21 hours ago - Stars: 852 - Forks: 126

weibocom/rill-flow

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

Language: Java - Size: 16.5 MB - Last synced: about 24 hours ago - Pushed: 1 day ago - Stars: 213 - Forks: 24

antvis/X6

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

Language: TypeScript - Size: 2.13 GB - Last synced: 1 day ago - Pushed: 2 days ago - Stars: 5,402 - Forks: 1,626

xmapst/osreapi

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

Language: Go - Size: 46.2 MB - Last synced: about 23 hours ago - Pushed: 1 day ago - Stars: 1 - Forks: 0

antvis/XFlow

React component for building interactive diagrams.

Language: TypeScript - Size: 100 MB - Last synced: 1 day ago - Pushed: about 1 month ago - Stars: 550 - Forks: 229

romnn/taski

async DAG task scheduling in Rust (WIP)

Language: Rust - Size: 2.74 MB - Last synced: 1 day ago - Pushed: 2 days ago - Stars: 0 - Forks: 0

DAGWorks-Inc/hamilton

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

Language: Jupyter Notebook - Size: 49.9 MB - Last synced: 24 days ago - Pushed: 24 days ago - Stars: 1,312 - Forks: 80

sogou/workflow

C++ Parallel Computing and Asynchronous Networking Framework

Language: C++ - Size: 4.48 MB - Last synced: 2 days ago - Pushed: 2 days ago - Stars: 12,494 - Forks: 2,337

boomerang-io/flow.service.workflow

Cloud-native workflows

Language: Java - Size: 3.85 MB - Last synced: 1 day ago - Pushed: 3 days ago - Stars: 6 - Forks: 8

HathorNetwork/hathor-core

HathorNetwork's fullnode core

Language: Python - Size: 11.4 MB - Last synced: 6 days ago - Pushed: 6 days ago - Stars: 80 - Forks: 22

Umar-Waseem/airflow-data-extraction-pipeline

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

Language: Python - Size: 13.7 KB - Last synced: 5 days ago - Pushed: 6 days ago - Stars: 0 - Forks: 0

infra-helpers/induction-airflow

Induction to Apache Airflow

Size: 1.15 MB - Last synced: 6 days ago - Pushed: almost 4 years ago - Stars: 1 - Forks: 0

allegro/bigflow

A Python framework for data processing on GCP.

Language: Python - Size: 107 MB - Last synced: about 24 hours ago - Pushed: 1 day ago - Stars: 116 - Forks: 23

MetOffice/dagrunner

!!!EXPERIMENTAL!!! Directed acyclic graph (DAG) runner and tools

Language: Python - Size: 86.9 KB - Last synced: 8 days ago - Pushed: 8 days ago - Stars: 1 - Forks: 0

omyllymaki/tiny-dag

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

Language: Python - Size: 326 KB - Last synced: 8 days ago - Pushed: 8 days ago - Stars: 1 - Forks: 0

byteball/obyte-explorer

View the DAG and all public transactions https://explorer.obyte.org

Language: JavaScript - Size: 725 KB - Last synced: 8 days ago - Pushed: 8 days ago - Stars: 6 - Forks: 21

jdoiro3/dagit

DaGit to learn Git Internals

Language: Go - Size: 136 KB - Last synced: 8 days ago - Pushed: 8 days ago - Stars: 12 - Forks: 1

paintdream/iris

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.

Language: C - Size: 1.06 MB - Last synced: 8 days ago - Pushed: 8 days ago - Stars: 18 - Forks: 2

alibaba/butterfly

🦋Butterfly，A JavaScript/React/Vue2 Diagramming library which concentrate on flow layout field. (基于JavaScript/React/Vue2的流程图组件)

Language: JavaScript - Size: 10.4 MB - Last synced: 8 days ago - Pushed: 27 days ago - Stars: 4,186 - Forks: 577

zflow-dev/zflow

Rust implementation of Flow Based Programming Graph specification

Language: Rust - Size: 28 MB - Last synced: 8 days ago - Pushed: 9 days ago - Stars: 44 - Forks: 2

SubstrateLabs/substrate-python

Substrate Python SDK

Language: Python - Size: 202 KB - Last synced: 8 days ago - Pushed: 9 days ago - Stars: 0 - Forks: 1

feluelle/airflint

Enforce Best Practices for all your Airflow DAGs. ⭐

Language: Python - Size: 307 KB - Last synced: 9 days ago - Pushed: 9 days ago - Stars: 80 - Forks: 2

thanawat1303/Airflow-Auto-Install-On-Docker

Language: Shell - Size: 10.7 MB - Last synced: 9 days ago - Pushed: 2 months ago - Stars: 1 - Forks: 0

XDagger/XIPs

XDAG Improvement Proposals (XIPs) describe standards for the XDAG platform, including core protocol specifications, client APIs, and so on.

Size: 29.3 KB - Last synced: 9 days ago - Pushed: over 5 years ago - Stars: 2 - Forks: 3

XDagger/QtXdagWallet Fork of amazingMan2017/QtXdagWallet

xdag wallet use qt

Language: C - Size: 10.7 MB - Last synced: 9 days ago - Pushed: over 5 years ago - Stars: 1 - Forks: 6

dagrs-dev/dagrs

A DAG engine build by Rust

Language: Rust - Size: 516 KB - Last synced: 9 days ago - Pushed: 9 days ago - Stars: 84 - Forks: 13

SubstrateLabs/substrate-typescript

Substrate TypeScript SDK

Language: TypeScript - Size: 645 KB - Last synced: 10 days ago - Pushed: 10 days ago - Stars: 2 - Forks: 0

XDagger/xdagj

XDAGJ is an implementation of XDAG in Java. https://xdag.io

Language: Java - Size: 23.9 MB - Last synced: 8 days ago - Pushed: 10 days ago - Stars: 106 - Forks: 58

thepipelinetool/thepipelinetool

A pipeline orchestration tool

Language: Rust - Size: 673 KB - Last synced: 14 days ago - Pushed: 24 days ago - Stars: 20 - Forks: 1

Setheum-Labs/Setheum

Setheum: zk-SNARKs Enabled DAG Powered Blockchain for Light-speed Smart Contracts. Ready for hacking 🚀

Language: Rust - Size: 46.8 MB - Last synced: 11 days ago - Pushed: 12 days ago - Stars: 24 - Forks: 13

wfcommons/WfFormat

The WfCommons JSON Schema for workflow instances and generators

Language: Python - Size: 66.4 KB - Last synced: 12 days ago - Pushed: 13 days ago - Stars: 5 - Forks: 4

aimclub/GOLEM

Graph Optimiser for Learning and Evolution of Models

Language: Python - Size: 22.4 MB - Last synced: 12 days ago - Pushed: 12 days ago - Stars: 51 - Forks: 6

ergesmema/SSSP-Java

A java implementation that introduces a way to find single source shortest paths from a given node to other nodes in the graph. The program works for both directed acyclic graphs(DAGs) as well as for directed graphs that include cycles. The input is given via a pre-validated text file written by the user, which contains the number of vertexes, number of edges and a list of edges and their weights, as well as comments if needed which are denoted by the hash sign(#) at the beginning of line. This information is read and processed, in order to determine the type of graph and to output the shortest paths from the given source node.

Language: Java - Size: 15.6 KB - Last synced: 13 days ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

PaddlePaddle/Serving

A flexible, high-performance carrier for machine learning models（『飞桨』服务化部署框架）

Language: C++ - Size: 156 MB - Last synced: 10 days ago - Pushed: 10 days ago - Stars: 877 - Forks: 243

argoproj/argo-workflows

Workflow Engine for Kubernetes

Language: Go - Size: 138 MB - Last synced: 15 days ago - Pushed: 15 days ago - Stars: 14,314 - Forks: 3,070

hatchet-dev/hatchet

A distributed, fault-tolerant task queue

Language: Go - Size: 10.1 MB - Last synced: 15 days ago - Pushed: 15 days ago - Stars: 3,180 - Forks: 99

zifeo/whiz

Modern DAG/tasks runner for multi-platform monorepos with live reloading, env management, pipes, and more in a tabbed view.

Language: Rust - Size: 683 KB - Last synced: 14 days ago - Pushed: 15 days ago - Stars: 17 - Forks: 15

Wittline/dag-example

Directed acyclic graph

Language: HTML - Size: 54.7 KB - Last synced: 15 days ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

guilhem/dag

Directed Acyclic Graph (DAG) implementation.

Language: Go - Size: 167 KB - Last synced: 15 days ago - Pushed: over 1 year ago - Stars: 1 - Forks: 0

juftin/airflow

Multi Container Airflow DAG Application

Language: Python - Size: 28.3 KB - Last synced: 15 days ago - Pushed: over 2 years ago - Stars: 1 - Forks: 0

erdogant/bnlearn

Python library for learning the graphical structure of Bayesian networks, parameter learning, inference and sampling methods.

Language: Jupyter Notebook - Size: 28.1 MB - Last synced: 14 days ago - Pushed: about 1 month ago - Stars: 445 - Forks: 44

xianghuzhao/paradag

A robust DAG implementation for parallel execution

Language: Python - Size: 50.8 KB - Last synced: 5 days ago - Pushed: 3 months ago - Stars: 61 - Forks: 8

astronomer/airflow-provider-fivetran-async

A new Airflow Provider for Fivetran, maintained by Astronomer and Fivetran

Language: Python - Size: 126 KB - Last synced: 16 days ago - Pushed: 17 days ago - Stars: 15 - Forks: 7

propensive/acyclicity

Monadic directed acyclic graph datastructures for Scala

Language: Scala - Size: 6.09 MB - Last synced: 17 days ago - Pushed: 17 days ago - Stars: 9 - Forks: 0

jamesgiu/quick-cyc

A component library for displaying pipelines in React. https://www.npmjs.com/package/quick-cyc

Language: TypeScript - Size: 953 KB - Last synced: 17 days ago - Pushed: 17 days ago - Stars: 0 - Forks: 0

aliyun/react-visual-modeling

A DAG React Component for visualization modeling, suitable for UML, database modeling, data warehouse construction.(一个基于React的数据可视化建模的DAG图，适用于UML，数据库建模，数据仓库建设等业务)

Language: JavaScript - Size: 368 KB - Last synced: 8 days ago - Pushed: over 2 years ago - Stars: 134 - Forks: 18

gsiddhad/Advanced-Algorithms

Implementation of Different Advanced Algorithms

Language: Python - Size: 17.6 KB - Last synced: 18 days ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

ucbrise/flor

🌻 FlorFlow: Flor, now with Dataflow

Language: Jupyter Notebook - Size: 44.7 MB - Last synced: 18 days ago - Pushed: about 2 months ago - Stars: 146 - Forks: 17

bartossh/Computantis

The Computantis is a backbone service for creating secure, reliable and performant solutions for transaction exchange and Byzantine fault-tolerant systems.

Language: Go - Size: 14.2 MB - Last synced: 19 days ago - Pushed: 19 days ago - Stars: 0 - Forks: 0

openvinotoolkit/model_server

A scalable inference server for models optimized with OpenVINO™

Language: C++ - Size: 82.8 MB - Last synced: 22 days ago - Pushed: 22 days ago - Stars: 635 - Forks: 193

PauloMigAlmeida/directed-acyclic-graph-builder-js

dag-builder-js is a simple-to-use Javascript DAG library with support for N:N vertices/edges. It supports validating that no cycle can be created in real-time, import/export states and it's built on SVG so you can render graphs pretty much anywhere.

Language: JavaScript - Size: 757 KB - Last synced: 15 days ago - Pushed: about 1 month ago - Stars: 14 - Forks: 1

r-causal/ggdag

:arrow_lower_left: :arrow_lower_right: An R package for working with causal directed acyclic graphs (DAGs)

Language: R - Size: 172 MB - Last synced: 15 days ago - Pushed: about 2 months ago - Stars: 425 - Forks: 28

mindee/tawazi

A DAG Scheduler library written in pure python

Language: Python - Size: 1.75 MB - Last synced: 2 days ago - Pushed: 3 days ago - Stars: 66 - Forks: 5

3amory99/Movies-Production-Insights-Pipeline

Unveiling Cinematic Brilliance: Illuminating the Future of Movie Production through Data-Driven Insights

Language: Java - Size: 24.8 MB - Last synced: 23 days ago - Pushed: 5 months ago - Stars: 0 - Forks: 4

deepcs233/jieba_fast

Use C Api and Swig to Speed up jieba 高效的中文分词库

Language: Python - Size: 39.8 MB - Last synced: 14 days ago - Pushed: over 2 years ago - Stars: 623 - Forks: 75

makisevon/flow

Flow is a simple DAG workflow engine.

Language: Rust - Size: 14.6 KB - Last synced: 23 days ago - Pushed: 23 days ago - Stars: 0 - Forks: 0

mykkelol/netsuite-data-pipeline

📈 Finance Data Pipeline to extract all GL posting transactions from NetSuite to S3 and Postgres for analysis, compliance, and automation

Language: Python - Size: 4.25 MB - Last synced: 23 days ago - Pushed: 23 days ago - Stars: 3 - Forks: 3

ErdemOzgen/blackdagger

Blackdagger is a DAG-based automation tool specifically used in DevOps, DevSecOps, MLOps, MLSecOps, and Continuous Red Teaming (CART).

Language: Go - Size: 7.19 MB - Last synced: 17 days ago - Pushed: 17 days ago - Stars: 30 - Forks: 5

DTStack/Taier

Taier is a big data development platform for submission, scheduling, operation and maintenance, and indicator information display

Language: Java - Size: 147 MB - Last synced: 24 days ago - Pushed: 24 days ago - Stars: 1,273 - Forks: 315

snowplow/factotum

A system to programmatically run data pipelines

Language: Rust - Size: 233 KB - Last synced: 17 days ago - Pushed: over 2 years ago - Stars: 217 - Forks: 12

web3-storage/pail

🪣 DAG based key value store.

Language: JavaScript - Size: 175 KB - Last synced: 22 days ago - Pushed: 24 days ago - Stars: 33 - Forks: 11

unicornultrafoundation/go-u2u

Implementation of Unicorn Ultra Decentralized Network in Golang

Language: Go - Size: 9.79 MB - Last synced: 25 days ago - Pushed: 25 days ago - Stars: 4 - Forks: 3

vitelabs/go-vite

Official Go implementation of the Vite protocol

Language: Go - Size: 129 MB - Last synced: 26 days ago - Pushed: 26 days ago - Stars: 320 - Forks: 94

mpolinowski/apache-airflow-intro

Introduction to Apache Airflow

Language: Python - Size: 9.77 KB - Last synced: 26 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

XDagger/xdag

XDAG (Dagger Coin) Official Main Repository. XDAG is a novel DAG based cryptocurrency.

Language: C - Size: 13.3 MB - Last synced: 9 days ago - Pushed: 2 months ago - Stars: 327 - Forks: 130

pgmpy/pgmpy

Python Library for learning (Structure and Parameter), inference (Probabilistic and Causal), and simulations in Bayesian Networks.

Language: Python - Size: 9.42 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 2,606 - Forks: 694

Barski-lab/cwl-airflow

Python package to extend Airflow functionality with CWL1.1 support

Language: Python - Size: 2.77 MB - Last synced: 27 days ago - Pushed: 7 months ago - Stars: 181 - Forks: 34

skit-ai/lute

Lute is a framework for writing compute DAGs

Language: Python - Size: 773 KB - Last synced: 29 days ago - Pushed: almost 3 years ago - Stars: 1 - Forks: 1

salesforce/apollo

An experimental multi-tenant distributed system platform

Language: Java - Size: 34.3 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 54 - Forks: 16

Lefteris-Souflas/Spark-Movies-Analytics

Utilizing Apache Spark & PySpark to analyze a movie dataset. Tasks include data exploration, identifying top-rated movies, training a linear regression model, and experimenting with Airflow.

Language: Jupyter Notebook - Size: 289 KB - Last synced: 29 days ago - Pushed: 29 days ago - Stars: 0 - Forks: 0

caicloud/cyclone

Powerful workflow engine and end-to-end pipeline solutions implemented with native Kubernetes resources. https://cyclone.dev

Language: Go - Size: 84.8 MB - Last synced: 29 days ago - Pushed: 7 months ago - Stars: 1,064 - Forks: 167

lchrennew/dragonfly-dag

完全支持Vue3和Vitejs的DAG流程图组件

Language: JavaScript - Size: 538 KB - Last synced: 7 days ago - Pushed: over 1 year ago - Stars: 72 - Forks: 17

WXzhongwang/pipeline-mvp

数据pipeline处理编排框架

Language: Java - Size: 465 KB - Last synced: about 1 month ago - Pushed: 6 months ago - Stars: 5 - Forks: 1

aliyun/react-monitor-dag

A React-based operation/monitoring DAG diagram.(基于React的运维/监控DAG图)

Language: JavaScript - Size: 163 KB - Last synced: 8 days ago - Pushed: 6 months ago - Stars: 68 - Forks: 11

ffan/dbus Fork of funkygao/dbus

yet another databus that transfer/transform pipeline data between plugins

Language: Go - Size: 940 KB - Last synced: about 1 month ago - Pushed: about 7 years ago - Stars: 3 - Forks: 0

ngneat/dag

🐠 An Angular service for managing directed acyclic graphs

Language: TypeScript - Size: 4.57 MB - Last synced: 15 days ago - Pushed: 6 months ago - Stars: 154 - Forks: 7

timkpaine/daggre

A convenience layer on top of dagre-d3/dagre-d3-es, for use in ipydagred3

Language: Python - Size: 448 KB - Last synced: about 20 hours ago - Pushed: about 1 month ago - Stars: 1 - Forks: 0

oort-tech/Olympus

Official C++ implementation of the Olympus protocol

Language: C++ - Size: 76.6 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 46 - Forks: 19

rudderlabs/rudder-airflow-provider

Rudderstack provider for Apache Airflow

Language: Python - Size: 80.1 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 1 - Forks: 1

noleme/noleme-flow

A library enabling DAG structuring of data processing programs such as ETLs

Language: Java - Size: 297 KB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 15 - Forks: 4

apache/airflow

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

Language: Python - Size: 264 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 34,343 - Forks: 13,504

boomerang-io/worker.cicd

CICD specific Flow Tasks

Language: Shell - Size: 940 KB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 0 - Forks: 1

intel/dffml

The easiest way to use Machine Learning. Mix and match underlying ML libraries and data set sources. Generate new datasets or modify existing ones with ease.

Language: Python - Size: 576 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 240 - Forks: 141

spacemeshos/go-spacemesh

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

Language: Go - Size: 133 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 734 - Forks: 204

orchest/orchest

Build data pipelines, the easy way 🛠️

Language: TypeScript - Size: 27.2 MB - Last synced: about 1 month ago - Pushed: 12 months ago - Stars: 4,019 - Forks: 251

XDAGWallet/xdag

XDAG (Dagger Coin) Official Main Repository. XDAG is a novel DAG based cryptocurrency.

Language: C - Size: 5.53 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 200 - Forks: 26

stitchfix/hamilton 📦

A scalable general purpose micro-framework for defining dataflows. THIS REPOSITORY HAS BEEN MOVED TO www.github.com/dagworks-inc/hamilton

Language: Python - Size: 7.72 MB - Last synced: 26 days ago - Pushed: 11 months ago - Stars: 874 - Forks: 39

leoho0722/airflow-mnist-example

Example for MLOps Pipeline using Airflow DAGs and MNIST handwritten CNN model

Language: Python - Size: 3.41 MB - Last synced: 27 days ago - Pushed: 29 days ago - Stars: 0 - Forks: 0

gcp-development/web-application

Web2 vs Web3

Language: Rust - Size: 384 MB - Last synced: about 1 month ago - Pushed: 10 months ago - Stars: 0 - Forks: 0

lazyCoder-max/BlazorStargazerModal

A library to provide simple interop access to stargazer wallet in Blazor applications

Language: C# - Size: 241 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 0 - Forks: 0

swimlane/ngx-graph

Graph visualization library for angular

Language: TypeScript - Size: 33.7 MB - Last synced: about 1 month ago - Pushed: 2 months ago - Stars: 910 - Forks: 283

composable-logs/composable-logs

Python library to run ML/data pipelines on stateless compute infrastructure (that may be ephemeral or serverless). Please see the documentation site with more details and demo:

Language: Python - Size: 1.17 MB - Last synced: 14 days ago - Pushed: 12 months ago - Stars: 17 - Forks: 0

cedricleroy/pyungo

Function dependencies resolution and execution

Language: Python - Size: 573 KB - Last synced: 11 days ago - Pushed: almost 4 years ago - Stars: 70 - Forks: 13

thekevinscott/Diagraph

A graph for representing LLM interactions

Language: Python - Size: 6.47 MB - Last synced: 4 days ago - Pushed: about 1 month ago - Stars: 2 - Forks: 0

hgncom/Core

Language: Python - Size: 421 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 0 - Forks: 0