From 9403581be5e369bf39306a526416def1d777633d Mon Sep 17 00:00:00 2001 From: Ian Letourneau Date: Sat, 2 Aug 2025 11:10:20 -0400 Subject: [PATCH] fix check to ensure prometheus operator is installed --- harmony/src/domain/topology/k8s_anywhere.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/harmony/src/domain/topology/k8s_anywhere.rs b/harmony/src/domain/topology/k8s_anywhere.rs index b072373..8ffbf75 100644 --- a/harmony/src/domain/topology/k8s_anywhere.rs +++ b/harmony/src/domain/topology/k8s_anywhere.rs @@ -271,11 +271,11 @@ impl K8sAnywhereTopology { &self, sender: &CRDPrometheus, ) -> Result { - let output = Command::new("sh") + let status = Command::new("sh") .args(["-c", "kubectl get crd -A | grep -i prometheuses"]) - .output() + .status() .map_err(|e| InterpretError::new(format!("could not connect to cluster: {}", e)))?; - if output.status.success() && output.stdout.is_empty() { + if !status.success() { if let Some(Some(k8s_state)) = self.k8s_state.get() { match k8s_state.source { K8sSource::LocalK3d => { @@ -300,7 +300,9 @@ impl K8sAnywhereTopology { return Ok(Outcome::noop()); } } + debug!("Prometheus operator is already present, skipping install"); + Ok(Outcome::success( "prometheus operator present in cluster".to_string(), ))