Skip to content

Gelencsér Szabolcs / cloud

Go to a project
Commit 6518029c by Guba Sándor
Options

mancelery: Adding TASK EXPIRE option

parent d9e168b3
Showing with 1 additions and 0 deletions
circle/manager/mancelery.py
...@@ -13,6 +13,7 @@ celery = Celery('manager', backend='amqp', ...@@ -13,6 +13,7 @@ celery = Celery('manager', backend='amqp',
'firewall.tasks.local_tasks']) 'firewall.tasks.local_tasks'])
celery.conf.update( celery.conf.update(
CELERY_TASK_RESULT_EXPIRES = 300,
CELERY_QUEUES=( CELERY_QUEUES=(
Queue(HOSTNAME + '.man', Exchange('manager', type='direct'), Queue(HOSTNAME + '.man', Exchange('manager', type='direct'),
routing_key="manager"), routing_key="manager"),
......
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