Skip to main content

send_operator_terminal

Function send_operator_terminal 

Source
async fn send_operator_terminal(
    tx: &Sender<Result<RtdlEvent, Status>>,
    node: &NodeEventContext,
    state: u32,
    reason: &str,
    runtime: &PlanRuntime,
)
Expand description

Stream the terminal event for a non-leaf RTDL operator node, and record the state so get_plan_status reflects it.