From 81cde5e688b09cb298c132cdb1dfccaae9d8fe10 Mon Sep 17 00:00:00 2001
From: alyssa <alyssa@mailc.net>
Date: Sat, 27 Dec 2025 02:44:39 -0500
Subject: [PATCH] fix(scheduled_tasks): get wal-g backups bucket from env

---
 crates/libpk/src/_config.rs         | 7 +++++++
 crates/scheduled_tasks/src/tasks.rs | 5 ++++-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/crates/libpk/src/_config.rs b/crates/libpk/src/_config.rs
index d51479ac..00d88ff8 100644
--- a/crates/libpk/src/_config.rs
+++ b/crates/libpk/src/_config.rs
@@ -95,6 +95,7 @@ pub struct ScheduledTasksConfig {
     pub expected_gateway_count: usize,
     pub gateway_url: String,
     pub prometheus_url: String,
+    pub walg_s3_bucket: String,
 }
 
 #[derive(Deserialize, Clone, Debug)]
@@ -157,6 +158,12 @@ impl PKConfig {
             .expect("missing avatar service config")
     }
 
+    pub fn scheduled_tasks(&self) -> &ScheduledTasksConfig {
+        self.scheduled_tasks
+            .as_ref()
+            .expect("missing scheduled_tasks config")
+    }
+
     pub fn premium(&self) -> &PremiumConfig {
         self.premium.as_ref().expect("missing premium config")
     }
diff --git a/crates/scheduled_tasks/src/tasks.rs b/crates/scheduled_tasks/src/tasks.rs
index 84773149..22ac0c5a 100644
--- a/crates/scheduled_tasks/src/tasks.rs
+++ b/crates/scheduled_tasks/src/tasks.rs
@@ -76,7 +76,10 @@ async fn update_basebackup_ts(repo: String) -> anyhow::Result<()> {
 
     env.insert(
         "WALG_S3_PREFIX".to_string(),
-        format!("s3://pluralkit-backups/{repo}/"),
+        format!(
+            "s3://{}/{repo}/",
+            libpk::config.scheduled_tasks().walg_s3_bucket
+        ),
     );
 
     let output = Command::new("wal-g")