205hlab-mirrors/authentik
2
0
Fork 0
mirror of https://github.com/goauthentik/authentik.git synced 2026-06-17 19:09:11 +03:00
Code Issues Packages Projects Releases Wiki Activity

packages/django-dramatiq-postgres: broker: fix task expiration (#17178)

Browse Source
This commit is contained in:
Marc 'risson' Schmitt
2025-10-02 14:45:56 +02:00
committed by GitHub
parent 40811eabc9
commit 8f644c3d3a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/django-dramatiq-postgres/django_dramatiq_postgres/broker.py
+1 -1
View File
@@ -465,7 +465,7 @@ class _PostgresConsumer(Consumer):
self.logger.debug("Running garbage collector")
count = self.query_set.filter(
state__in=(TaskState.DONE, TaskState.REJECTED),
mtime__lte=timezone.now() - timedelta(seconds=Conf().task_purge_interval),
mtime__lte=timezone.now() - timedelta(seconds=Conf().task_expiration),
result_expiry__lte=timezone.now(),
).delete()
self.logger.info("Purged messages in all queues", count=count)