diff --git a/circle/manager/mancelery.py b/circle/manager/mancelery.py index 74bdb49..aa40b0b 100755 --- a/circle/manager/mancelery.py +++ b/circle/manager/mancelery.py @@ -11,7 +11,8 @@ celery = Celery('manager', backend='amqp', 'vm.tasks.local_periodic_tasks', 'vm.tasks.local_agent_tasks', 'storage.tasks.local_tasks', - 'firewall.tasks.local_tasks']) + 'storage.tasks.periodic_tasks', + 'firewall.tasks.local_tasks', ]) celery.conf.update( CELERY_TASK_RESULT_EXPIRES=300, @@ -32,6 +33,11 @@ celery.conf.update( 'schedule': timedelta(seconds=10), 'options': {'queue': 'localhost.man'} }, + 'storage.periodic_tasks': { + 'task': 'storage.tasks.periodic_tasks.garbage_collector', + 'schedule': timedelta(hours=1), + 'options': {'queue': 'localhost.man'} + }, } )