Struct EnsembleTask 

pub struct EnsembleTask<T, R> { /* private fields */ }

Runs the same Task runs times concurrently and reduces the responses into one — self-consistency prompting: sample an LLM call several times (usually with temperature > 0) and combine the answers instead of trusting a single draw.

Implementations

impl<T, R> EnsembleTask<T, R>

where T: Task + 'static, R: Fn(Vec<String>) -> String + Send + Sync,

pub fn new(id: impl Into<String>, inner: T, runs: usize, reducer: R) -> Self

Run inner runs times (at least 1) and combine the responses with reducer.

pub fn with_next_action(self, next_action: NextAction) -> Self

Trait Implementations

impl<T, R> Task for EnsembleTask<T, R>

where T: Task + 'static, R: Fn(Vec<String>) -> String + Send + Sync,

fn id(&self) -> &str

Unique identifier for this task.

fn run<'life0, 'async_trait>( &'life0 self, context: Context, ) -> Pin<Box<dyn Future<Output = Result<TaskResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the task with the given context.