fix: vacuum for done jobs

geofmureithi · Jan 5, 2025 · 3fc8d77 · 3fc8d77
1 parent 535e50c
commit 3fc8d77
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/packages/apalis-redis/src/storage.rs b/packages/apalis-redis/src/storage.rs
@@ -818,7 +818,7 @@ where
     async fn vacuum(&mut self) -> Result<usize, RedisError> {
         let vacuum_script = self.scripts.vacuum.clone();
         vacuum_script
-            .key(self.config.dead_jobs_set())
+            .key(self.config.done_jobs_set())
             .key(self.config.job_data_hash())
             .invoke_async(&mut self.conn)
             .await