Oi.Dispatch.Orchestrator (oi v0.6.3)

Orchestrates barrier-synchronized execution of plan stages.

Fans out tasks per stage via the configured executor, collects results, enforces barrier before next stage. Results are merged into the drafting.

Summary

Functions

dispatch(plan, drafting, conf)

Functions

dispatch(plan, drafting, conf)

@spec dispatch(
  Oi.Compile.Planning.Plan.t(),
  Oi.Dispatch.Drafting.t(),
  Oi.Dispatch.Config.t()
) ::
  {:ok, Oi.Dispatch.Drafting.t()} | {:error, term()}