From 0c0d0e85bebe1dacd5ac86085d653b24f1dd0cec Mon Sep 17 00:00:00 2001 From: Hicham Azimani Date: Thu, 28 Nov 2024 15:55:25 +0100 Subject: [PATCH] fix: reenque_orphaned for RedisStorage --- packages/apalis-redis/src/storage.rs | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/packages/apalis-redis/src/storage.rs b/packages/apalis-redis/src/storage.rs index c5f5fee..e366151 100644 --- 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 = reenqueue_orphaned .key(consumers_set)