webql/runner/run_batch

Copy Markdown

Values

run

pub fn run(
  batch: List(plan.Step(task)),
  edges: List(plan.Edge),
  engine: engine.Engine(task, memory.Memory(storage), error),
  memory: memory.Memory(storage),
  run_plan: fn(
    plan.Plan(task),
    memory.Memory(storage),
    engine.Engine(task, memory.Memory(storage), error),
    dynamic.Dynamic,
  ) -> task,
) -> task

Runs the next batch in a plan.