@@ -567,18 +567,10 @@ pub async fn run<'a>(
567567) -> anyhow:: Result < DatasetRows > {
568568 let mut processes_to_observe = exec_plan. external_processes_to_observe . unwrap_or ( vec ! [ ] ) ; // external procs to observe are cloned here.
569569
570- // Set as minimum grace period, keeping it to stay backwards compatibile
571- let mut max_grace_millis = 2000_u64 ;
572570 // run the application if there is anything to run
573571 if !exec_plan. processes_to_execute . is_empty ( ) {
574572 for proc in exec_plan. processes_to_execute {
575573 print ! ( "> starting process {}" , proc. name. green( ) ) ;
576- if let Some ( startup_grace) = proc. startup_grace {
577- let millis = startup_grace. as_millis ( ) as u64 ;
578- if millis > max_grace_millis {
579- max_grace_millis = millis;
580- }
581- }
582574
583575 let process_to_observe = run_process ( proc) ?;
584576
@@ -589,9 +581,9 @@ pub async fn run<'a>(
589581 }
590582 }
591583
592- print ! ( "> waiting for application to settle: {}ms" , max_grace_millis ) ;
584+ print ! ( "> waiting for application to settle" ) ;
593585 std:: io:: stdout ( ) . flush ( ) ?;
594- tokio:: time:: sleep ( tokio:: time:: Duration :: from_millis ( max_grace_millis ) ) . await ;
586+ tokio:: time:: sleep ( tokio:: time:: Duration :: from_millis ( 2000 ) ) . await ;
595587 println ! ( " {}" , "\t ✓" . green( ) ) ;
596588
597589 let start_time = Utc :: now ( ) . timestamp_millis ( ) ;
@@ -818,7 +810,6 @@ pub mod tests {
818810 down : None ,
819811 redirect : Some ( Redirect :: Null ) ,
820812 process_type : ProcessType :: BareMetal ,
821- startup_grace : None ,
822813 } ;
823814 let proc_to_observe = run_process ( & proc) ?;
824815
@@ -852,7 +843,6 @@ pub mod tests {
852843 down : None ,
853844 redirect : Some ( Redirect :: Null ) ,
854845 process_type : ProcessType :: BareMetal ,
855- startup_grace : None ,
856846 } ;
857847 let procs_to_observe = run_process ( & proc) ?;
858848 let stop_handle = metrics_logger:: start_logging ( vec ! [ procs_to_observe] ) ?;
0 commit comments