DAG-Based Parallel Workflow Engine

⚙️ Camshaft AI

A DAG-based parallel workflow engine that routes tasks across Claude, Ollama, and TaskFlow AI — with real-time cost tracking, automatic failover, and autonomous worker mode. Built in Go for production workloads.

70/70 Tests Passing
1.3-3x Parallel Speedup
4 LLM Provider Tiers
$0 Ollama Local Cost
Capabilities

What Camshaft AI Does

🔀

DAG-Based Parallel Execution

Tasks scheduled as a directed acyclic graph with automatic dependency resolution. Independent tasks run concurrently across workers, delivering 1.3-3x speedup on production workloads.

DAG SchedulerConcurrencyZero Deadlocks
🤖

Multi-LLM Routing

Intelligent priority routing across Claude API, Ollama, and TaskFlow AI. Auto-selects Haiku for simple tasks, Sonnet for medium, Opus for complex. Graceful fallback through the provider chain.

ClaudeOllamaAuto-Select
💰

Real-Time Cost Tracking

Every LLM call is metered with per-task cost attribution. Set cost ceilings to halt execution when budget is exceeded. Route to free local models automatically.

Cost CeilingPer-Task MeteringBudget Control
🏭

Autonomous Worker Mode

Continuous daemon that polls TaskFlow for pending tasks, claims them, executes with multi-LLM routing, and reports results. Supports horizontal scaling with multiple workers.

TaskFlowAuto-PollingHorizontal Scale
🔍

Research Agent & RAG

Built-in research agent with Qdrant and Chroma vector store clients for retrieval-augmented generation. Scout engine explores solution spaces before committing to execution.

QdrantChromaVector Search
📊

Observability & Tracing

Structured span tracing for every workflow. LLM call logging, metrics collection, and WebSocket hub for real-time dashboard streaming.

TracingMetricsWebSocket
Why Camshaft AI

What Sets It Apart

1. Parallel-First, Not Sequential-Default

Builds a DAG from your objective, identifies independent branches, and runs them concurrently. The scheduler handles dependency ordering, resource limits, and result aggregation automatically.

1.34x speedup measured on 10-task production workloads with 3 parallel workers.

2. Multi-LLM with Automatic Failover

Chains Claude, Ollama, and TaskFlow AI with priority-based routing. If Claude hits a rate limit, execution continues on Ollama. Your workflow never stalls.

3. Cost-Aware by Design

Auto-selects the cheapest model capable of each task. Set a cost ceiling and the engine halts or routes remaining tasks to free local models.

Ollama on local hardware: $0.00 per task.

4. Worker Mode for Production Pipelines

Runs as an autonomous daemon. Workers poll TaskFlow, claim tasks atomically, execute with full LLM routing, and push results back. Scale by launching more workers.

95.2% success rate across 42 autonomous tasks in benchmarks.

Technology

Built With

Language
Go 1.22+ with structured concurrency and goroutine pools
Scheduler
DAG-based parallel executor with dependency resolution
LLM Providers
Claude (Haiku/Sonnet/Opus), Ollama, TaskFlow AI
Vector Stores
Qdrant and Chroma clients for RAG retrieval
Real-Time
WebSocket hub for live execution streaming
FAQ

Common Questions

What is DAG-based parallel execution?

A DAG models task dependencies as a graph. Camshaft AI decomposes objectives into tasks, identifies independent branches, and runs them concurrently — eliminating idle time and delivering 25-300% speedup.

Can I run everything locally without API keys?

Yes. Configure Ollama as the primary provider and everything runs on your hardware at zero cost. The engine works identically with local or cloud models.

How does cost tracking work?

Every LLM call logs provider, model, token counts, and dollar cost. Set a cost ceiling per execution — the engine halts or reroutes to free models before exceeding budget.

What tasks can Camshaft AI execute?

Any task an LLM can decompose: code generation, research, document drafting, data transformation, API workflows, test generation, and multi-step reasoning chains.

Ready to Get Started?

Run complex AI workflows with parallel execution, multi-LLM routing, and real-time cost tracking.