From 7fc1136e04d836b516d0197b23698f86277568d5 Mon Sep 17 00:00:00 2001 From: Nick Hudson Date: Thu, 26 Sep 2024 16:16:41 -0500 Subject: [PATCH] pass scheduled backup name to make sure its patched correctly --- tembo-operator/src/cloudnativepg/cnpg_utils.rs | 3 ++- tembo-operator/src/cloudnativepg/hibernate.rs | 10 +++++++++- 2 files changed, 11 insertions(+), 2 deletions(-) diff --git a/tembo-operator/src/cloudnativepg/cnpg_utils.rs b/tembo-operator/src/cloudnativepg/cnpg_utils.rs index 97958a433..c026fdba2 100644 --- a/tembo-operator/src/cloudnativepg/cnpg_utils.rs +++ b/tembo-operator/src/cloudnativepg/cnpg_utils.rs @@ -156,6 +156,7 @@ pub async fn patch_cluster_merge( pub async fn patch_scheduled_backup_merge( cdb: &CoreDB, ctx: &Arc, + backup_name: &str, patch: serde_json::Value, ) -> Result<(), Action> { let name = cdb.name_any(); @@ -167,7 +168,7 @@ pub async fn patch_scheduled_backup_merge( let scheduled_backup_api: Api = Api::namespaced(ctx.client.clone(), namespace); let pp = PatchParams::apply("patch_merge"); let _ = scheduled_backup_api - .patch(&name, &pp, &Patch::Merge(&patch)) + .patch(backup_name, &pp, &Patch::Merge(&patch)) .await .map_err(|e| { error!("Error patching cluster: {}", e); diff --git a/tembo-operator/src/cloudnativepg/hibernate.rs b/tembo-operator/src/cloudnativepg/hibernate.rs index 7cb10cf24..346b7aecd 100644 --- a/tembo-operator/src/cloudnativepg/hibernate.rs +++ b/tembo-operator/src/cloudnativepg/hibernate.rs @@ -283,6 +283,7 @@ async fn update_scheduled_backups( let scheduled_backup_value = cdb.spec.stop; for sb in scheduled_backups { + let scheduled_backup_name = sb.metadata.name.as_deref().unwrap_or(&name); let scheduled_backup_suspend_status = sb.spec.suspend.unwrap_or_default(); if scheduled_backup_suspend_status != scheduled_backup_value { @@ -292,7 +293,14 @@ async fn update_scheduled_backups( } }); - match patch_scheduled_backup_merge(cdb, ctx, patch_scheduled_backup_spec).await { + match patch_scheduled_backup_merge( + cdb, + ctx, + scheduled_backup_name, + patch_scheduled_backup_spec, + ) + .await + { Ok(_) => { info!( "Toggled scheduled backup suspend of {} to '{}'",