Module distributed 

Distributed work queue and executor adapters Distributed execution adapters

Provides LocalWorkQueue (in-process, for single-node and testing) and DistributedDagExecutor (wraps any WorkQueuePort to distribute DAG waves across workers).

Design

DistributedDagExecutor
   │
   ├─ resolve wave N (topological sort already done by DagExecutor)
   ├─ enqueue every node in the wave as a WorkTask
   ├─ spawn worker tasks that call try_dequeue + service.execute
   └─ collect_results when all tasks in wave are Completed

Structs

DistributedDagExecutor

Executes a DAG wave using a WorkQueuePort to distribute node-level tasks across workers.

LocalWorkQueue

In-memory work queue for single-node deployments and unit tests.