Skip to content

Commit e1b5835

Browse files
authored
add timeout layer (#60)
1 parent a788a19 commit e1b5835

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

crates/iceberg/src/io/storage.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818
use std::sync::Arc;
1919

20-
use opendal::layers::RetryLayer;
20+
use opendal::layers::{RetryLayer, TimeoutLayer};
2121
#[cfg(feature = "storage-azblob")]
2222
use opendal::services::AzblobConfig;
2323
#[cfg(feature = "storage-gcs")]
@@ -183,7 +183,7 @@ impl Storage {
183183

184184
// Transient errors are common for object stores; however there's no
185185
// harm in retrying temporary failures for other storage backends as well.
186-
let operator = operator.layer(RetryLayer::new());
186+
let operator = operator.layer(TimeoutLayer::new()).layer(RetryLayer::new());
187187

188188
Ok((operator, relative_path))
189189
}

0 commit comments

Comments
 (0)