Trait BatchExecutor 

pub trait BatchExecutor: Send + Sync {
    // Required method
    fn invoke(&self, inputs: BatchInputs) -> Result<BatchOutputs>;
}

Runtime-neutral batch executor for future WASM and process adapters.

Adapters must accept empty BatchInputs and return an empty BatchOutputs unless the adapter has a documented reason to fail. Batch shaping is a host concern.

This trait remains topology-blind: validating output ports against workflow contracts and capabilities belongs to the engine or host adapter that owns those declarations, not to the batch executor.

Invocation may block. The engine is responsible for running adapters on an appropriate task and for triggering any adapter-specific cancellation hook.

Required Methods

fn invoke(&self, inputs: BatchInputs) -> Result<BatchOutputs>

Invoke the adapter with host-owned input packets.

Errors

Returns an error if the adapter cannot complete the batch invocation.

Implementors