@@ -246,12 +246,18 @@ impl ResolvedFaultTolerantExecutionConfig {
246246 Self :: insert_if_present (
247247 & mut config_properties,
248248 "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( ) ) ) ,
250253 ) ;
251254 Self :: insert_if_present (
252255 & mut config_properties,
253256 "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( ) ) ) ,
255261 ) ;
256262 Self :: insert_if_present (
257263 & mut config_properties,
@@ -530,7 +536,7 @@ mod tests {
530536 ) ;
531537 assert_eq ! (
532538 fte_config. config_properties. get( "retry-max-delay" ) ,
533- Some ( & "1m30s " . to_string( ) )
539+ Some ( & "90s " . to_string( ) )
534540 ) ;
535541 assert_eq ! (
536542 fte_config. config_properties. get( "retry-delay-scale-factor" ) ,
@@ -688,7 +694,10 @@ mod tests {
688694 async fn test_exchange_manager_config_overrides ( ) {
689695 let mut config_overrides = HashMap :: new ( ) ;
690696 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+ ) ;
692701
693702 let config = FaultTolerantExecutionConfig {
694703 retry_policy : RetryPolicy :: Task ,
0 commit comments