fix: checks deployment status ready replicas rather than pod name since the pod name is not necessarily matching the deployment name and often has a random generated number in it

harmony/src/domain/topology/k8s.rs

@@ -52,6 +52,19 @@ impl K8sClient {
         })
     }
 
+    pub async fn get_deployment(
+        &self,
+        name: &str,
+        namespace: Option<&str>,
+    ) -> Result<Option<Deployment>, Error> {
+        let deps: Api<Deployment> = if let Some(ns) = namespace {
+            Api::namespaced(self.client.clone(), ns)
+        } else {
+            Api::default_namespaced(self.client.clone())
+        };
+        Ok(deps.get_opt(name).await?)
+    }
+
     pub async fn get_pod(&self, name: &str, namespace: Option<&str>) -> Result<Option<Pod>, Error> {
         let pods: Api<Pod> = if let Some(ns) = namespace {
             Api::namespaced(self.client.clone(), ns)

harmony/src/modules/storage/ceph/ceph_osd_replacement_score.rs

@@ -50,13 +50,21 @@ impl<T: Topology + K8sclient> Interpret<T> for PrepCephOsdReplacementInterpret {
                 0,
             )
             .await?;
-        client
+        let dep = client
-            .get_pod(&self.score.osd_name, Some(&self.score.rook_ceph_namespace))
+            .get_deployment(&self.score.osd_name, Some(&self.score.rook_ceph_namespace))
             .await?;
 
-        Ok(Outcome::success(
+        match dep.unwrap().status.and_then(|s| s.ready_replicas) {
-            "Successfully prepared rook-ceph-cluster for disk replacement".to_string(),
+            Some(0) => Ok(Outcome::success(
-        ))
+                "Successfully prepared rook-ceph-cluster for disk replacement".to_string(),
+            )),
+            Some(_) => Err(InterpretError::new({
+                "Deployment still has ready replicas".to_string()
+            })),
+            None => Err(InterpretError::new({
+                "Failed to get rook-ceph-cluster status".to_string()
+            })),
+        }
     }
 
     fn get_name(&self) -> InterpretName {
@@ -75,5 +83,3 @@ impl<T: Topology + K8sclient> Interpret<T> for PrepCephOsdReplacementInterpret {
         todo!()
     }
 }
-
-impl PrepCephOsdReplacementInterpret {}