Package com.tnsai.coordination.workflow

Class DAGExecutor

java.lang.Object

com.tnsai.coordination.workflow.DAGExecutor

public final class DAGExecutor
extends Object

Executes workflow steps as a Directed Acyclic Graph (DAG). Steps with no dependencies run in parallel; dependent steps wait for their prerequisites.

Example usage:

 WorkflowResult result = DAGExecutor.builder()
     .step("fetch-a", fetchAgentA)
     .step("fetch-b", fetchAgentB)
     .step("merge", mergeAgent, List.of("fetch-a", "fetch-b"))
     .step("report", reportAgent, List.of("merge"))
     .build()
     .execute(new WorkflowContext("dag-1"));
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DAGExecutor.Builder

Method Summary

Modifier and Type	Method	Description
static DAGExecutor.Builder	builder()
WorkflowResult	execute(WorkflowContext context)	Executes the DAG, running independent steps in parallel.
CompletableFuture<WorkflowResult>	executeAsync(WorkflowContext context)	Executes the DAG asynchronously.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

execute

public WorkflowResult execute(WorkflowContext context)

Executes the DAG, running independent steps in parallel. Steps wait for all their dependencies to complete before executing.

executeAsync

public CompletableFuture<WorkflowResult> executeAsync(WorkflowContext context)

Executes the DAG asynchronously.

builder

public static DAGExecutor.Builder builder()