pub trait Observer: Send + Sync {
// Required methods
fn on_node_start(&self, node_name: &str, inputs: &Value);
fn on_node_end(&self, node_name: &str, outputs: &Value);
fn on_node_error(&self, node_name: &str, error: &str);
}Expand description
Observer trait for observing node execution events
Required Methods§
Sourcefn on_node_start(&self, node_name: &str, inputs: &Value)
fn on_node_start(&self, node_name: &str, inputs: &Value)
Called when a node starts execution
Sourcefn on_node_end(&self, node_name: &str, outputs: &Value)
fn on_node_end(&self, node_name: &str, outputs: &Value)
Called when a node completes successfully
Sourcefn on_node_error(&self, node_name: &str, error: &str)
fn on_node_error(&self, node_name: &str, error: &str)
Called when a node encounters an error