reset time range for next batch

CDLUC3 · Nov 4, 2024 · a3440ea · a3440ea
1 parent 6053b1c
commit a3440ea
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ezidapp/management/commands/proc-cleanup-async-queues_v2.py b/ezidapp/management/commands/proc-cleanup-async-queues_v2.py
@@ -177,7 +177,7 @@ def run(self):
                     self.sleep(ASYNC_CLEANUP_SLEEP)
                     last_id = 0
                     min_age_ts = max_age_ts
-                    max_age_ts = min_age_ts + ASYNC_CLEANUP_SLEEP
+                    max_age_ts = int(time.time()) - django.conf.settings.DAEMONS_EXPUNGE_MAX_AGE_SEC
                     time_range = Q(updateTime__gte=min_age_ts) & Q(updateTime__lte=max_age_ts)
                     time_range_str = f"updated between: {self.seconds_to_date(min_age_ts)} and {self.seconds_to_date(max_age_ts)}"
             else: