/** * Orchestration domain state, task graphs, node lifecycles, and bounded * recursive execution telemetry for higher-level worker coordination. */ import type { OrchestrationTaskContract } from '../../../../events/orchestration.js'; export type OrchestrationMode = 'single-worker' | 'parallel-workers' | 'review-loop' | 'graph-execute'; export type OrchestrationNodeRole = 'planner' | 'orchestrator' | 'engineer' | 'reviewer' | 'fixer' | 'verifier' | 'researcher' | 'integrator'; export type OrchestrationNodeState = 'pending' | 'ready' | 'running' | 'blocked' | 'completed' | 'failed' | 'cancelled'; export type OrchestrationGraphState = 'planning' | 'ready' | 'running' | 'blocked' | 'completed' | 'failed' | 'cancelled'; export interface OrchestrationNodeRecord { id: string; title: string; role: OrchestrationNodeRole; status: OrchestrationNodeState; parentNodeId?: string | undefined; childNodeIds: string[]; dependencyNodeIds: string[]; taskId?: string | undefined; agentId?: string | undefined; latestMessage?: string | undefined; startedAt?: number | undefined; endedAt?: number | undefined; error?: string | undefined; contract?: OrchestrationTaskContract | undefined; } export interface OrchestrationGraphRecord { id: string; title: string; mode: OrchestrationMode; status: OrchestrationGraphState; nodeOrder: string[]; nodes: Map; createdAt: number; startedAt?: number | undefined; endedAt?: number | undefined; lastRecursionGuard?: { depth: number; activeAgents: number; reason: string; nodeId?: string | undefined; triggeredAt: number; }; } export interface OrchestrationDomainState { revision: number; lastUpdatedAt: number; source: string; graphs: Map; activeGraphIds: string[]; totalGraphs: number; totalCompletedGraphs: number; totalFailedGraphs: number; recursionGuardTrips: number; } export declare function createInitialOrchestrationState(): OrchestrationDomainState; //# sourceMappingURL=orchestration.d.ts.map