Method run

lib-engine/src/blueprint/task.rs:271–518

(&self)

    }

    fn run(&self) {
        if self.request.is_self_managed() {
            engine_task::enable_log_file_writer(&self.info_context(), &self.log_file_writer);
        }

        let _span = self.span.enter();
        info!("blueprint task {} started", self.id());

        self.logger.log(EngineEvent::Info(
            self.get_event_details(BlueprintStep::Start),
            EventMessage::new("Qovery Engine starts to execute the blueprint deployment".to_string(), None),
        ));

        let guard = scopeguard::guard((), |_| {
            hack::remove_gke_gcloud_auth_plugin_cache();
            self.logger.log(EngineEvent::Info(
                self.get_event_details(BlueprintStep::Terminated),
                EventMessage::new("Qovery Engine has terminated the blueprint deployment".to_string(), None),
            ));
            let Some(is_terminated_tx) = self.is_terminated.0.write().unwrap().take() else {
                return;
            };
            let _ = is_terminated_tx.send(());
        });

        // 1. Create infrastructure context
        let infra_context = match self.infrastructure_context() {
            Ok(infra_ctx) => infra_ctx,
            Err(err) => {
                self.logger.log(EngineEvent::Error(*err, None));
                return;
            }
        };

        let metrics_registry = Arc::new(infra_context.metrics_registry().clone_dyn());
        let record =
            metrics_registry.start_record(self.request.target_environment.long_id, StepLabel::Service, StepName::Total);

        let mut target_env = self.request.target_environment.clone();

        let deployment_ret = (|| -> Result<BlueprintTaskOutcome, Box<EngineError>> {
            // 2. Clone blueprint repo
            let (blueprint_dir, blueprint_info) = self.clone_blueprint_repo(&infra_context)?;

            // 3. Parse QBM manifest
            let manifest = self.parse_manifest(&blueprint_dir)?;

            // 4. Inject context variables
            inject_context_variables(
                &mut target_env,
                &self.request.cloud_provider.kind,
                &self.request.kubernetes.region,
                &self.request.kubernetes.name,
            );

            // 5. Resolve spec
            let resolved_spec = ResolvedBlueprintSpec::resolve(&manifest, &target_env.spec_overrides).map_err(|e| {
                Box::new(EngineError::new_blueprint_error(