File tree Expand file tree Collapse file tree 2 files changed +8
-0
lines changed
Expand file tree Collapse file tree 2 files changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -49,6 +49,7 @@ use tracing::{
4949 warn,
5050} ;
5151
52+ use crate :: api_client:: clients:: shared:: stalled_stream_protection_config;
5253use crate :: auth:: AuthError ;
5354use crate :: auth:: consts:: * ;
5455use crate :: auth:: scope:: is_scopes;
@@ -86,6 +87,7 @@ pub fn client(region: Region) -> Client {
8687 . region ( region)
8788 . retry_config ( RetryConfig :: standard ( ) . with_max_attempts ( 3 ) )
8889 . sleep_impl ( SharedAsyncSleep :: new ( TokioSleep :: new ( ) ) )
90+ . stalled_stream_protection ( stalled_stream_protection_config ( ) )
8991 . app_name ( app_name ( ) )
9092 . build ( ) ,
9193 )
Original file line number Diff line number Diff line change @@ -42,6 +42,7 @@ use aws_smithy_runtime_api::client::identity::{
4242use aws_smithy_types:: error:: display:: DisplayErrorContext ;
4343use aws_types:: region:: Region ;
4444use aws_types:: request_id:: RequestId ;
45+ use aws_types:: sdk_config:: StalledStreamProtectionConfig ;
4546use fig_aws_common:: app_name;
4647use fig_telemetry_core:: {
4748 Event ,
@@ -101,6 +102,11 @@ pub(crate) fn client(region: Region) -> Client {
101102 . region ( region)
102103 . retry_config ( retry_config)
103104 . sleep_impl ( SharedAsyncSleep :: new ( TokioSleep :: new ( ) ) )
105+ . stalled_stream_protection (
106+ StalledStreamProtectionConfig :: enabled ( )
107+ . grace_period ( std:: time:: Duration :: from_secs ( 60 ) )
108+ . build ( ) ,
109+ )
104110 . app_name ( app_name ( ) )
105111 . build ( ) ;
106112 Client :: new ( & sdk_config)
You can’t perform that action at this time.
0 commit comments