fix: Make Api namespaced for patching status

demeter-run · Nov 1, 2024 · f06d308 · f06d308
1 parent fd6ea53
commit f06d308
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/controller.rs b/src/controller.rs
@@ -344,13 +344,14 @@ impl K8sContext {
 
     async fn patch_statuses(&self) -> anyhow::Result<()> {
         let api: Api<HydraDoomNode> = Api::all(self.client.clone());
-
         let crds = api.list(&ListParams::default()).await?;
 
         let mut awaitables = vec![];
         for crd in &crds {
             awaitables.push(async {
                 let name = crd.name_any();
+                let api: Api<HydraDoomNode> =
+                    Api::namespaced(self.client.clone(), &crd.namespace().unwrap());
                 if let Err(err) = api
                     .patch_status(
                         &name,
@@ -359,7 +360,10 @@ impl K8sContext {
                     )
                     .await
                 {
-                    warn!(err = err.to_string(), "Failed to status for CRD.");
+                    warn!(
+                        err = err.to_string(),
+                        "Failed to update status for CRD {}.", name
+                    );
                 };
             })
         }