Skip to content

Commit e43dea0

Browse files
make errors from stalled stream protection retryable (#6501)
1 parent c488354 commit e43dea0

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

quickwit/quickwit-aws/src/error.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ where E: AwsRetryable
3535
match self {
3636
SdkError::ConstructionFailure(_) => false,
3737
SdkError::TimeoutError(_) => true,
38-
SdkError::DispatchFailure(_) => false,
38+
SdkError::DispatchFailure(failure) => failure.is_io() || failure.is_timeout(),
3939
SdkError::ResponseError(_) => true,
4040
SdkError::ServiceError(error) => error.err().is_retryable(),
4141
_ => false,

quickwit/quickwit-lambda-client/src/invoker.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ fn invoke_error_to_lambda_error(error: SdkError<InvokeError>) -> LambdaInvokeErr
8989

9090
let is_timeout = match &error {
9191
SdkError::TimeoutError(_) => true,
92-
SdkError::DispatchFailure(failure) => failure.is_timeout(),
92+
SdkError::DispatchFailure(failure) => failure.is_io() || failure.is_timeout(),
9393
SdkError::ServiceError(service_error) => matches!(
9494
service_error.err(),
9595
InvokeError::EfsMountTimeoutException(_) | InvokeError::SnapStartTimeoutException(_)

0 commit comments

Comments
 (0)