(&self)
| 291 | } |
| 292 | |
| 293 | fn run(&self) { |
| 294 | engine_task::enable_log_file_writer(&self.info_context(), &self.log_file_writer); |
| 295 | let _span = self.span.enter(); |
| 296 | |
| 297 | self.logger.log(EngineEvent::Info( |
| 298 | self.get_event_details(ClusterAnalysisStep::Start), |
| 299 | EventMessage::new_from_safe("Qovery Engine has started the cluster analysis".to_string()), |
| 300 | )); |
| 301 | |
| 302 | let guard = scopeguard::guard((), |_| { |
| 303 | hack::remove_gke_gcloud_auth_plugin_cache(); |
| 304 | self.logger.log(EngineEvent::Info( |
| 305 | self.get_event_details(ClusterAnalysisStep::Terminated), |
| 306 | EventMessage::new_from_safe("Qovery Engine has terminated the cluster analysis".to_string()), |
| 307 | )); |
| 308 | if let Some(is_terminated_tx) = self.is_terminated.0.write().unwrap().take() { |
| 309 | let _ = is_terminated_tx.send(()); |
| 310 | } |
| 311 | }); |
| 312 | |
| 313 | match self.run_analysis() { |
| 314 | Ok(report) => self.report_success(report), |
| 315 | Err(error) => self.logger.log(EngineEvent::Error( |
| 316 | error.clone_engine_error_with_stage(Stage::ClusterAnalysis(ClusterAnalysisStep::Error)), |
| 317 | Some(EventMessage::new_from_safe("Cluster analysis failed".to_string())), |
| 318 | )), |
| 319 | } |
| 320 | |
| 321 | drop(guard); |
| 322 | engine_task::disable_log_file_writer(&self.log_file_writer); |
| 323 | } |
| 324 | |
| 325 | fn cancel(&self, force_requested: bool) -> bool { |
| 326 | self.cancel_requested.store( |
nothing calls this directly
no test coverage detected