File tree 2 files changed +8
-0
lines changed 2 files changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -49,6 +49,7 @@ use tracing::{
49
49
warn,
50
50
} ;
51
51
52
+ use crate :: api_client:: clients:: shared:: stalled_stream_protection_config;
52
53
use crate :: auth:: AuthError ;
53
54
use crate :: auth:: consts:: * ;
54
55
use crate :: auth:: scope:: is_scopes;
@@ -86,6 +87,7 @@ pub fn client(region: Region) -> Client {
86
87
. region ( region)
87
88
. retry_config ( RetryConfig :: standard ( ) . with_max_attempts ( 3 ) )
88
89
. sleep_impl ( SharedAsyncSleep :: new ( TokioSleep :: new ( ) ) )
90
+ . stalled_stream_protection ( stalled_stream_protection_config ( ) )
89
91
. app_name ( app_name ( ) )
90
92
. build ( ) ,
91
93
)
Original file line number Diff line number Diff line change @@ -42,6 +42,7 @@ use aws_smithy_runtime_api::client::identity::{
42
42
use aws_smithy_types:: error:: display:: DisplayErrorContext ;
43
43
use aws_types:: region:: Region ;
44
44
use aws_types:: request_id:: RequestId ;
45
+ use aws_types:: sdk_config:: StalledStreamProtectionConfig ;
45
46
use fig_aws_common:: app_name;
46
47
use fig_telemetry_core:: {
47
48
Event ,
@@ -101,6 +102,11 @@ pub(crate) fn client(region: Region) -> Client {
101
102
. region ( region)
102
103
. retry_config ( retry_config)
103
104
. 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
+ )
104
110
. app_name ( app_name ( ) )
105
111
. build ( ) ;
106
112
Client :: new ( & sdk_config)
You can’t perform that action at this time.
0 commit comments