vbatts/quay
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Merge pull request #1517 from coreos-inc/fix-queue-cleanup-worker

Browse source 
Fix the queue cleanup worker to delete the items that have expired, n…
This commit is contained in:
josephschorr 2016-06-04 14:08:16 -04:00
commit 72b7bb5b10
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
workers/queuecleanupworker.py
View file

@ -21,11 +21,10 @@ class QueueCleanupWorker(Worker):
""" Performs garbage collection on the queueitem table. """
with UseThenDisconnect(app.config):
while True:
# Find all queue items older than the threshold (typically a week) that have no additional
# retries and delete them.
# Find all queue items older than the threshold (typically a week) and delete them.
threshold_ago = datetime.now() - DELETION_DATE_THRESHOLD
to_delete = list(QueueItem.select().where(QueueItem.processing_expires >= threshold_ago,
QueueItem.retries_remaining == 0)
to_delete = list(QueueItem.select()
.where(QueueItem.processing_expires <= threshold_ago)
.limit(BATCH_SIZE))
if len(to_delete) < DELETION_COUNT_THRESHOLD: