Trait StepCallback 

pub trait StepCallback<'e>: Send {
    // Required method
    fn on_step(&mut self, node_name: &str, step: usize, duration: Duration);
}

每步回调 — run_inline 在每个节点执行完成后调用。

用于 wrapper（如 run_execution_loop）追踪 execution_log 或发射 per-node 事件。 回调在 commit + checkpoint 之后、take_control 之前调用。

Required Methods

fn on_step(&mut self, node_name: &str, step: usize, duration: Duration)

节点执行完成后的回调。

• node_name — 刚执行完的节点名
• step — 当前步数（从 1 开始）
• duration — 节点执行耗时

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<'e> StepCallback<'e> for NoopStepCallback