Skip to content

Roadmap

Pure orchestration library + Optional framework components

Current Status (v1.x)

Core orchestration is stable with 800+ tests. Key capabilities: - Task orchestration with dependency trees and priority execution - 12+ executors (REST, WebSocket, gRPC, SSH, Docker, CrewAI, LiteLLM, MCP) - Multi-protocol API (A2A, MCP, JSON-RPC) - Built-in scheduler (internal polling + external gateway) - CLI and ConfigManager - DuckDB + PostgreSQL storage


Near-term

Feature Status Description
Distributed Core Planned Multi-node orchestration with task leasing
Protocol Abstraction In Progress Unified adapter interface for all protocols
GraphQL Adapter Planned Query interface for complex task trees

Distributed Core

Enable multi-node deployments with centralized coordination. See design doc for details.

  • Node registry with health checks
  • Task leasing with automatic expiry
  • Placement constraints (executor type, resources)
  • PostgreSQL-based coordination

Protocol Abstraction

Unified interface for protocol adapters. Phase 1 complete:

  • Capabilities registry (api/capabilities.py) as single source of truth for all 15 operations
  • A2A adapter simplified to agent-level actions only (execute, generate, cancel)
  • MCP adapter auto-generates 15 tools from the registry
  • Native API (POST /tasks) as primary programmatic interface
  • Method discovery endpoint (GET /tasks/methods)

Remaining:

class ProtocolAdapter(Protocol):
    async def handle_execute_request(self, request: dict) -> dict: ...
    async def handle_status_request(self, request: dict) -> dict: ...

GraphQL Adapter

Optional strawberry-graphql based adapter for querying task trees.


Mid-term

Feature Status Description
MQTT Adapter Planned IoT/Edge AI agent communication
Observability Hooks Planned Pluggable metrics (Prometheus, OpenTelemetry)
Workflow Patterns Planned Map-Reduce, Fan-Out/Fan-In, Circuit Breaker
Testing Utilities Planned TaskMocker, workflow simulation

Future

Feature Status Description
VS Code Extension Idea Task tree visualization
Hot Reload Idea Auto-reload on code changes
WebSocket Server Idea Bidirectional agent collaboration

Not Planned

These are application-level concerns, not orchestration:

  • User Management / Auth / RBAC
  • Multi-Tenancy
  • Audit Logging (use observability hooks)
  • Secret Management (use Vault, AWS Secrets Manager)
  • Dashboard UI (separate project: apflow-webapp)

Completed

Feature Version Notes
Fluent API (TaskBuilder) v1.x Type-safe chainable task creation
CLI → API Gateway v1.x CLI routes through API when configured
ConfigManager v1.x Unified configuration management
Task Model Extensions v1.x task_tree_id, origin_type, migrations
Executor Access Control v1.x Environment-based filtering
Scheduler v1.x Internal scheduler + external gateway integration