fix(configuration): AWS ThroughPutBelowMinimum errors and timouts

near · Jul 4, 2024 · ac9b38e · ac9b38e
1 parent f02339c
commit ac9b38e
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 6 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/configuration/src/configs/lake.rs b/configuration/src/configs/lake.rs
@@ -1,3 +1,4 @@
+use aws_sdk_s3::config::StalledStreamProtectionConfig;
 use near_lake_framework::near_indexer_primitives::near_primitives;
 use serde_derive::Deserialize;
 
@@ -21,6 +22,7 @@ impl LakeConfig {
             "",
         );
         aws_sdk_s3::Config::builder()
+            .stalled_stream_protection(StalledStreamProtectionConfig::disabled())
             .credentials_provider(credentials)
             .region(aws_types::region::Region::new(
                 self.aws_default_region.clone(),

diff --git a/configuration/src/configs/tx_details_storage.rs b/configuration/src/configs/tx_details_storage.rs
@@ -1,3 +1,4 @@
+use aws_sdk_s3::config::StalledStreamProtectionConfig;
 use serde_derive::Deserialize;
 
 use crate::configs::{deserialize_optional_data_or_env, required_value_or_panic};
@@ -23,6 +24,7 @@ impl TxDetailsStorageConfig {
             "",
         );
         aws_sdk_s3::Config::builder()
+            .stalled_stream_protection(StalledStreamProtectionConfig::disabled())
             .credentials_provider(credentials)
             .endpoint_url(
                 self.aws_endpoint