Skip to main content

drive_plan

Function drive_plan 

Source
async fn drive_plan(
    plan: Plan,
    client: RobonixSystemExecutorExecuteClient<Channel>,
    events_tx: Sender<ForestEvent>,
    forest_revision: Arc<AtomicU64>,
)
Expand description

Drive one dispatched plan’s Execute stream to completion, forwarding node states for visualisation and collecting terminal results. Sends exactly one PlanDone when the stream ends. Runs as its own task so the supervisor loop never blocks on a single tree — concurrent trees form the forest.