Skip to content

Gelencsér Szabolcs / cloud

Go to a project
Commit 96abca5c by Guba Sándor Committed by Őry Máté
Options

storage: fixed periodic tasks queue names

parent 123418f8
Showing with 2 additions and 2 deletions
circle/storage/tasks/periodic_tasks.py
......@@ -34,11 +34,11 @@ def garbage_collector(timeout=15):
:type timeout: int
"""
for ds in DataStore.objects.all():
queue_name = ds.get_remote_queue_name('storage')
queue_name = ds.get_remote_queue_name('storage', priority='fast')
files = set(remote_tasks.list_files.apply_async(
args=[ds.path], queue=queue_name).get(timeout=timeout))
disks = set(ds.get_deletable_disks())
queue_name = ds.get_remote_queue_name('storage')
queue_name = ds.get_remote_queue_name('storage', priority='slow')
for i in disks & files:
logger.info("Image: %s at Datastore: %s moved to trash folder." %
(i, ds.path))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment