retrying
fun Embedder.retrying(maxAttempts: Int = RetryingEmbedder.DEFAULT_MAX_ATTEMPTS, initialDelay: Duration = RetryingEmbedder.DEFAULT_INITIAL_DELAY, maxDelay: Duration = RetryingEmbedder.DEFAULT_MAX_DELAY, factor: Double = RetryingEmbedder.DEFAULT_FACTOR, jitter: Double = RetryingEmbedder.DEFAULT_JITTER, retryOn: (Throwable) -> Boolean = { true }): RetryingEmbedder
Wraps this embedder in a RetryingEmbedder that retries transient failures with jittered backoff.
val embedder = Embedder { text -> openAi.embed(text) }.retrying(maxAttempts = 4)Content copied to clipboard
See RetryingEmbedder for the semantics; CancellationException is never retried.