@@ -246,12 +246,18 @@ impl ResolvedFaultTolerantExecutionConfig {
246
246
Self :: insert_if_present (
247
247
& mut config_properties,
248
248
"retry-initial-delay" ,
249
- config. retry_initial_delay . as_ref ( ) ,
249
+ config
250
+ . retry_initial_delay
251
+ . as_ref ( )
252
+ . map ( |d| format ! ( "{}s" , d. as_secs( ) ) ) ,
250
253
) ;
251
254
Self :: insert_if_present (
252
255
& mut config_properties,
253
256
"retry-max-delay" ,
254
- config. retry_max_delay . as_ref ( ) ,
257
+ config
258
+ . retry_max_delay
259
+ . as_ref ( )
260
+ . map ( |d| format ! ( "{}s" , d. as_secs( ) ) ) ,
255
261
) ;
256
262
Self :: insert_if_present (
257
263
& mut config_properties,
@@ -530,7 +536,7 @@ mod tests {
530
536
) ;
531
537
assert_eq ! (
532
538
fte_config. config_properties. get( "retry-max-delay" ) ,
533
- Some ( & "1m30s " . to_string( ) )
539
+ Some ( & "90s " . to_string( ) )
534
540
) ;
535
541
assert_eq ! (
536
542
fte_config. config_properties. get( "retry-delay-scale-factor" ) ,
@@ -688,7 +694,10 @@ mod tests {
688
694
async fn test_exchange_manager_config_overrides ( ) {
689
695
let mut config_overrides = HashMap :: new ( ) ;
690
696
config_overrides. insert ( "custom.property" . to_string ( ) , "custom-value" . to_string ( ) ) ;
691
- config_overrides. insert ( "exchange.s3.upload.part-size" . to_string ( ) , "overridden-value" . to_string ( ) ) ;
697
+ config_overrides. insert (
698
+ "exchange.s3.upload.part-size" . to_string ( ) ,
699
+ "overridden-value" . to_string ( ) ,
700
+ ) ;
692
701
693
702
let config = FaultTolerantExecutionConfig {
694
703
retry_policy : RetryPolicy :: Task ,
0 commit comments