Tasker Core

High-performance Rust workflow orchestration with PostgreSQL-native messaging. Tasker Core provides DAG-based task execution, event-driven coordination, and comprehensive state management for complex workflows. Supports PGMQ (default, single-dependency) or RabbitMQ (high-throughput) backends.

Status: Alpha Ready | Version: 0.1.0

• DAG-Based Workflows - Define complex workflows as directed acyclic graphs with dependencies
• Flexible Messaging - PGMQ (PostgreSQL-native, zero extra dependencies) or RabbitMQ (high-throughput)
• Event-Driven - Real-time step discovery with push notifications and polling fallback
• Multi-Language Workers - Rust native, Ruby via FFI, Python via PyO3, TypeScript FFI
• Production-Ready (Alpha) - Circuit breakers, health monitoring, zero race conditions, 50+ metrics

• Order fulfillment workflows with inventory, payment, and shipping coordination
• Payment processing pipelines with retry logic and idempotency
• ETL pipelines with complex dependencies and parallel execution
• Microservices orchestration across distributed systems

• Simple cron jobs (use native cron)
• Single-step operations (overhead not justified)
• Sub-millisecond requirements (~10-20ms architectural overhead)

• Rust 1.75+ | PostgreSQL 17+ (uuidv7 support) | Docker (recommended)
• Optional: RabbitMQ (for high-throughput messaging)

# Start PostgreSQL (includes PGMQ extension)
docker-compose up -d postgres

# Run migrations
export DATABASE_URL="postgresql://tasker:tasker@localhost/tasker_rust_test"
cargo sqlx migrate run

# Start orchestration server
docker-compose --profile server up -d

# Create a task
curl -X POST http://localhost:8080/v1/tasks \
  -H "Content-Type: application/json" \
  -d '{"template_name": "linear_workflow", "namespace": "example"}'

# Check health
curl http://localhost:8080/health

Full Guide: docs/guides/quick-start.md

┌─────────────────────────────────────────────────────────────┐
│                     Client Applications                     │
│                   (REST API / CLI / SDK)                    │
└──────────────────────────┬──────────────────────────────────┘
                           │
                           ▼
┌─────────────────────────────────────────────────────────────┐
│              Tasker Orchestration Server                    │
│    Task Init → Step Discovery → Enqueueing → Finalization  │
└──────────┬──────────────────────────────────┬───────────────┘
           │                                  │
           ▼                                  ▼
┌──────────────────────┐          ┌──────────────────────────┐
│  PostgreSQL + Broker │◄────────►│  Namespace Worker Pools  │
│ (PGMQ or RabbitMQ)   │          │  (Horizontal Scaling)    │
└──────────────────────┘          └──────────────────────────┘

Key Patterns: Dual state machines (12 task + 9 step states), event-driven with polling fallback, autonomous workers, PostgreSQL as source of truth. Messaging via PGMQ (default) or RabbitMQ.

Deep Dive: Architecture Documentation

Benchmarked in 10-instance cluster (2 orchestration, 2 each worker type). Each step involves ~19 DB operations, 2 message queue round-trips, and full state machine lifecycle.

Horizontal scaling for orchestration and workers. SQL performance at sub-3ms with 5K+ tasks. All FFI languages within 3ms of each other (framework-dominated overhead).

Full Benchmarks: docs/benchmarks/README.md

All documentation is organized in the Documentation Hub:

AI Assistant Context: CLAUDE.md | Development Guide: docs/development/

# Build and test (always use --all-features)
cargo build --all-features
cargo test --all-features

# Lint
cargo fmt && cargo clippy --all-targets --all-features

# Run server
cargo run --bin tasker-server

See CLAUDE.md for complete development context.

1. Review CLAUDE.md for project context
2. Run tests: cargo test --all-features
3. Format and lint before PR
4. See Documentation Hub for documentation structure

MIT License - see LICENSE for details.

Production-ready workflow orchestration at scale.

Quick Start | Documentation | Examples