@@ -86,25 +86,26 @@ impl CronJob for RefreshTravelStates {
8686 let mut stdout = cmd. stdout . take ( ) . unwrap ( ) ;
8787 let mut stderr = cmd. stderr . take ( ) . unwrap ( ) ;
8888 log:: info!( "Waiting" ) ;
89- let status = await_cancellable ! ( cmd. wait( ) , stop_signal, {
90- log:: error!( "Killing connector process..." ) ;
91- let kill_err = cmd. kill( ) . await ;
92- log:: warn!( "Stdout:" ) ;
93- let mut out_buf = String :: new( ) ;
94- if let Err ( e) = stdout. read_to_string( & mut out_buf) . await {
95- log:: error!( "Failed to read stdout: {}" , e) ;
96- } else {
97- log:: warn!( "{out_buf}" ) ;
98- }
99- log:: warn!( "Stderr:" ) ;
100- let mut err_buf = String :: new( ) ;
101- if let Err ( e) = stderr. read_to_string( & mut err_buf) . await {
102- log:: error!( "Failed to read stderr: {}" , e) ;
103- } else {
104- log:: warn!( "{err_buf}" ) ;
105- }
106- kill_err?;
107- } ) ;
89+ let status = cmd. wait ( ) . await ?;
90+ // let status = await_cancellable!(cmd.wait(), stop_signal, {
91+ // log::error!("Killing connector process...");
92+ // let kill_err = cmd.kill().await;
93+ // log::warn!("Stdout:");
94+ // let mut out_buf = String::new();
95+ // if let Err(e) = stdout.read_to_string(&mut out_buf).await {
96+ // log::error!("Failed to read stdout: {}", e);
97+ // } else {
98+ // log::warn!("{out_buf}");
99+ // }
100+ // log::warn!("Stderr:");
101+ // let mut err_buf = String::new();
102+ // if let Err(e) = stderr.read_to_string(&mut err_buf).await {
103+ // log::error!("Failed to read stderr: {}", e);
104+ // } else {
105+ // log::warn!("{err_buf}");
106+ // }
107+ // kill_err?;
108+ // });
108109 log:: info!( "Waited" ) ;
109110 log:: info!( "Connector process exited with: {}" , status) ;
110111 drop ( cmd) ;
0 commit comments