Struct RunnableRetry 

pub struct RunnableRetry<I: Send + Sync + 'static, O: Send + Sync + 'static> { /* private fields */ }

A Runnable wrapper that retries the inner Runnable on failure.

Implementations

impl<I: Send + Sync + 'static, O: Send + Sync + 'static> RunnableRetry<I, O>

pub fn new(runnable: Box<dyn RunnableAny>, retry_config: RetryConfig) -> Self

Creates a new RunnableRetry from a boxed RunnableAny.

Trait Implementations

impl<I, O: Send + Sync + 'static> Runnable<I, O> for RunnableRetry<I, O>

where I: Clone + Send + Sync + 'static,

type Error = LcelError

Error type.

fn invoke<'life0, 'async_trait>( &'life0 self, input: I, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<O, Self::Error>> + Send + 'async_trait>>

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

Transforms single input to output.

fn stream<'life0, 'async_trait>( &'life0 self, input: I, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<O, Self::Error>> + Send>>, Self::Error>> + Send + 'async_trait>>

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

Streaming output - for real-time responses (LLM, etc).

fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Output>, Self::Error>> + Send + 'async_trait>>

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

Batch processing - transforms multiple inputs to outputs.

fn transform<'life0, 'async_trait>( &'life0 self, input: Pin<Box<dyn Stream<Item = Result<Input, Self::Error>> + Send>>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<Output, Self::Error>> + Send>>, Self::Error>> + Send + 'async_trait>>

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

Stream-to-stream transformation - the core of LCEL streaming.