fix: reenque_orphaned for RedisStorage

geofmureithi · Nov 28, 2024 · 0c0d0e8 · 0c0d0e8
1 parent 47af9df
commit 0c0d0e8
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/packages/apalis-redis/src/storage.rs b/packages/apalis-redis/src/storage.rs
@@ -947,9 +947,7 @@ where
         let active_jobs_list = self.config.active_jobs_list();
         let signal_list = self.config.signal_list();
 
-        let now = Utc::now();
-        let duration = now.signed_duration_since(dead_since);
-        let dead_since = duration.num_seconds();
+        let dead_since = dead_since.timestamp();
 
         let res: Result<usize, RedisError> = reenqueue_orphaned
             .key(consumers_set)