Class CoordinatorAgent

Index

Constructors

Methods

assignTasks decomposeSpec getDecomposition getReadyTasks markComplete markFailed validateDAG

Constructors

constructor

new CoordinatorAgent(): CoordinatorAgent
Returns CoordinatorAgent

Methods

assignTasks

assignTasks(specId: string, agentMap: AgentCapabilityMap): number
Task 4.4: Assign tasks to agents via capability matching. In production this calls SPARQL; here we use the provided capability map.
Parameters
- specId: string
- agentMap: AgentCapabilityMap
Returns number
- Defined in packages/core/src/core/coordination/coordinator-agent.ts:101

decomposeSpec

decomposeSpec(_specTitle: string, _capabilities: string[]): SpecDecomposition
Task 4.3: Decompose a SPEC into ≥10 tasks with correct dependsOn. Returns a DAG where every task has resolved capability + trust requirements.
Parameters
- _specTitle: string
- _capabilities: string[]
Returns SpecDecomposition
- Defined in packages/core/src/core/coordination/coordinator-agent.ts:34

getDecomposition

getDecomposition(specId: string): SpecDecomposition | undefined
Parameters
- specId: string
Returns SpecDecomposition | undefined
- Defined in packages/core/src/core/coordination/coordinator-agent.ts:143

getReadyTasks

getReadyTasks(specId: string): TaskSpec[]
Get tasks that are ready to run (all dependencies complete).
Parameters
- specId: string
Returns TaskSpec[]
- Defined in packages/core/src/core/coordination/coordinator-agent.ts:121

markComplete

markComplete(specId: string, taskId: string, result?: unknown): void
Parameters
- specId: string
- taskId: string
- Optionalresult: unknown
Returns void
- Defined in packages/core/src/core/coordination/coordinator-agent.ts:130

markFailed

markFailed(specId: string, taskId: string): void
Parameters
- specId: string
- taskId: string
Returns void
- Defined in packages/core/src/core/coordination/coordinator-agent.ts:138

validateDAG

validateDAG(specId: string): { cycle?: string[]; valid: boolean }
Validate DAG has no cycles (DFS)
Parameters
- specId: string
Returns { cycle?: string[]; valid: boolean }
- Defined in packages/core/src/core/coordination/coordinator-agent.ts:148