Module scheduler 

Structs

StepResult

Result of running a single step, with metadata for streaming.

Functions

run_workflow

Run an entire workflow: stages sequentially, steps within parallel stages concurrently. Sends StepResults to tx as each step completes. Returns true if all required steps passed.