Skip to main content

run_node_with_metadata_sink

Function run_node_with_metadata_sink 

Source
pub async fn run_node_with_metadata_sink<E, M>(
    node: &E,
    ctx: NodeContext,
    inputs: PortsIn,
    outputs: PortsOut,
    metadata_sink: Arc<M>,
) -> Result<()>
where E: NodeExecutor + ?Sized, M: MetadataSink + 'static,
Expand description

Execute a single node through the runtime boundary and collect metadata.

ยงErrors

Returns an error if metadata collection fails or the node executor reports one.