M09 · Workflow orchestration · parallel agents

DAG orchestration

Explicit dependencies, parallel lanes and a visible critical path.

$ python -m fde_toolkit dag --workflow aml

Workflow

the order an FDE actually runs it in

  1. 1Decompose the case into typed tasks with declared dependencies.
  2. 2Topologically sort and group tasks into parallel waves.
  3. 3Execute waves, validating each node's typed output.
  4. 4Apply retry policy by error class, respecting idempotency.
  5. 5Report status, latency and the critical path per run.

Function output

deterministic trace

wave 1: case_intake                      0.4s
wave 2: kyc_check | sanctions | graph    2.1s (parallel)
wave 3: risk_score -> policy -> decision 1.7s
6 tasks, critical path 4.2s, sequential baseline 7.9s