akashi_workflow 0.3.1
akashi_workflow: ^0.3.1 copied to clipboard
Deterministic, code-driven multi-agent orchestration for Akashi: bounded-concurrency fan-out, typed pipelines, retries with backoff, timeouts, cancellation, and an event stream.
Changelog #
0.3.1 #
- Docs: live-demo link now points to https://akashi.azanello.com (the canonical custom domain). No code or API changes.
0.3.0 #
- Initial release of deterministic, code-driven multi-agent orchestration.
Workflow— an orchestrator with bounded concurrency (maxConcurrency), default + per-taskRetryPolicy(geometric backoff + jitter), per-task and global (deadline) timeouts, cooperative cancellation (linkable to an externalCancellationToken), amaxTasksrunaway-budget guard, and a broadcasteventsstream ofWorkflowEvents.run/runCatching— single task (throwing vs. settled).parallel— fan-out, fail-fast with sibling cancellation.parallelSettled— fan-out returning everyTaskResult(successes + failures).pipeline— stream items through a typedPipelinewith no barrier between stages.
Task/TaskResult/TaskContext,RetryPolicy,Semaphore, sealedWorkflowEvents, and typedPipelinebuilder.agentTask/objectTask— wrap an AkashiAgent(run/generateObject) as a workflow task, with cancellation wired through to the agent loop.