taskgraph-rs ⚓

A NASA-grade, zero-dependency, no_std DAG task orchestrator library for Rust.

🚀 Vision

taskgraph-rs is a lightweight, high-performance engine designed to execute interdependent tasks (DAG - Directed Acyclic Graph) in parallel. Built for environments where reliability, safety, and performance are non-negotiable.

Core Pillars:

• Zero-Unsafe — #![forbid(unsafe_code)] strictly enforced
• Zero-Deps — No dependencies by default, no_std compatible
• Dual Runtime — Sync (no_std/IoT) and Async (Tokio) support
• 14.8M tasks/sec — Lock-free atomic orchestration, benchmarked

🎯 Perfect for

✅ IoT & Embedded systems (ESP32, ARM — runs in < 1KB RAM)
✅ Game engines in Rust (parallel asset loading pipelines)
✅ Medical / Defense (offline, air-gapped, zero cloud)
✅ CLI tools with complex step dependencies
✅ Any Rust app needing a parallel task pipeline

❌ Not a replacement for Apache Airflow (no UI, no cron)
❌ Not for distributed multi-server workflows

📦 Installation

[dependencies]
taskgraph-rs = "0.1"

# Async support (Tokio)
# taskgraph-rs = { version = "0.1", features = ["async"] }

🛠️ Usage

Synchronous (no_std / IoT / CLI)

use taskgraph::{Task, TaskGraph, StaticStore};

fn main() -> taskgraph::Result<()> {
    let storage = StaticStore::<10>::new()?;
    let mut graph = TaskGraph::new(storage);

    let id_a = graph.task(Task::new_static("TaskA", || Ok(())), &[])?;
    let _id_b = graph.task(Task::new_static("TaskB", || Ok(())), &[id_a])?;

    graph.run_sync()?;
    Ok(())
}

Asynchronous (Tokio)

#[tokio::main]
async fn main() -> taskgraph::Result<()> {
    let mut graph = TaskGraph::new(taskgraph::DynamicStore::new());

    let t = Task::new_async("Fetch", || Box::pin(async { Ok(()) }))
        .with_timeout(Duration::from_secs(30))
        .with_retries(3);

    graph.task(t, &[])?;
    graph.run_async().await?;
    Ok(())
}

🛡️ Security & Reliability

• No Panics — Zero unwrap() in the core library
• Cycle Detection — Kahn's Algorithm, deterministic
• Panic Isolation — One task panics, others continue
• Timeout — Async tasks cancelled cleanly on timeout

⚖️ License

Free for non-commercial use — see LICENSE

Built by Ferrolab · ferrolab@tutamail.com