Function execute_blocking 

pub fn execute_blocking(
    pipeline: &Pipeline,
    inputs: Vec<Arc<dyn Value>>,
    ctx: Arc<TaskContext>,
    watcher: &dyn PipelineWatcher,
) -> Result<PipelineRunResult, ExecutionError>

Run execute synchronously, blocking the calling thread until the pipeline completes.

This creates a new single-threaded Tokio runtime internally. Use this from non-async code (e.g. a CLI main function or a C FFI callback). Equivalent to Python’s run_pipeline_blocking.

Panics

Panics if called from within an existing Tokio runtime (nested runtimes are not supported). Use execute directly in that case.