README
¶
Hanzo Tasks
Durable workflow execution engine for AI agent orchestration.
Introduction
Hanzo Tasks is a durable execution engine that powers AI agent orchestration in the Hanzo ecosystem. It enables developers to build scalable, fault-tolerant workflows that automatically handle intermittent failures and retry failed operations.
Tasks provides the backbone for:
- Playground spaces -- each space maps to a Tasks namespace
- Agent execution -- each agent runs as a Tasks worker
- Durable cron and batch jobs -- reliable scheduled and bulk operations
MIT licensed. See LICENSE.
Getting Started
Build
make tasksd
Run
./tasksd start
Or with a config file:
./tasksd --config-file config/development-sqlite.yaml --allow-no-auth start
Build from source
go build ./cmd/tasksd/
./tasksd start
Module
github.com/hanzoai/tasks
Integration
Hanzo Tasks integrates with the broader Hanzo ecosystem:
- Playground connects to the Tasks server via the durable-execution SDK
- Base embeds Tasks for durable cron/batch execution
- Each playground space = a Tasks namespace
- Each agent = a Tasks worker
Repository
This repository contains the source code of the Hanzo Tasks server.
The wire is luxfi/zap (binary, native, on _tasks._tcp:9999).
There is no gRPC and no go.temporal.io anywhere in the build.
To drive Tasks from Go, depend on pkg/sdk — the native
ZAP client. To embed the server in a Go process (e.g. a Hanzo Base
app), depend on pkg/tasks and call tasks.Embed().
Browser clients hit the JSON shim at /v1/tasks/* and the realtime
stream at /v1/tasks/events (Server-Sent Events). AI agents hit the
MCP surface at /v1/tasks/mcp (JSON-RPC 2.0).
Contributing
See CONTRIBUTING.md for development setup and guidelines.
License
Directories
¶
| Path | Synopsis |
|---|---|
|
cmd
|
|
|
tasksd
command
|
|
|
pkg
|
|
|
sdk
Package sdk is the Hanzo Tasks workflow SDK.
|
Package sdk is the Hanzo Tasks workflow SDK. |
|
sdk/activity
Package activity provides the call-site helpers that activity code uses inside a Hanzo Tasks worker.
|
Package activity provides the call-site helpers that activity code uses inside a Hanzo Tasks worker. |
|
sdk/client
Package client is the Hanzo Tasks workflow client.
|
Package client is the Hanzo Tasks workflow client. |
|
sdk/converter
Package converter provides the EncodedValue surface returned by Client.QueryWorkflow and other RPCs that ship an opaque payload.
|
Package converter provides the EncodedValue surface returned by Client.QueryWorkflow and other RPCs that ship an opaque payload. |
|
sdk/examples
Package examples — workflow patterns that exercise the Hanzo Tasks engine end-to-end via the native ZAP SDK at pkg/sdk/client.
|
Package examples — workflow patterns that exercise the Hanzo Tasks engine end-to-end via the native ZAP SDK at pkg/sdk/client. |
|
sdk/inproc
Package inproc provides an in-process client.Transport that dispatches RPCs synchronously into a frontend ZAP handler.
|
Package inproc provides an in-process client.Transport that dispatches RPCs synchronously into a frontend ZAP handler. |
|
sdk/temporal
Package temporal provides native Hanzo Tasks workflow primitives (retry policy, error model, failure serialisation) with zero dependency on any go.temporal.io/* package.
|
Package temporal provides native Hanzo Tasks workflow primitives (retry policy, error model, failure serialisation) with zero dependency on any go.temporal.io/* package. |
|
sdk/worker
Package worker is the Hanzo Tasks worker runtime.
|
Package worker is the Hanzo Tasks worker runtime. |
|
sdk/workflow
Package workflow is the workflow-code-facing API of the Hanzo Tasks SDK.
|
Package workflow is the workflow-code-facing API of the Hanzo Tasks SDK. |
|
tasks
Package tasks provides the Hanzo Tasks client for Go applications.
|
Package tasks provides the Hanzo Tasks client for Go applications. |
|
Package ui exposes the built Vite bundle as an embedded filesystem.
|
Package ui exposes the built Vite bundle as an embedded filesystem. |