Skip to content

Fukász Rómeó Ervin / cloud

Go to a project
Commit 8e4a7d6f by Guba Sándor
Options

mancelery: updated to cache backend

parent 115e42fc
Showing with 4 additions and 1 deletions
circle/manager/mancelery.py
...@@ -4,8 +4,9 @@ from kombu import Queue, Exchange ...@@ -4,8 +4,9 @@ from kombu import Queue, Exchange
from os import getenv from os import getenv
HOSTNAME = "localhost" HOSTNAME = "localhost"
CACHE_URI = getenv("CACHE_URI", "pylibmc://127.0.0.1:11211/")
celery = Celery('manager', backend='amqp', celery = Celery('manager',
broker=getenv("AMQP_URI"), broker=getenv("AMQP_URI"),
include=['vm.tasks.local_tasks', include=['vm.tasks.local_tasks',
'vm.tasks.local_periodic_tasks', 'vm.tasks.local_periodic_tasks',
...@@ -15,6 +16,8 @@ celery = Celery('manager', backend='amqp', ...@@ -15,6 +16,8 @@ celery = Celery('manager', backend='amqp',
'firewall.tasks.local_tasks', ]) 'firewall.tasks.local_tasks', ])
celery.conf.update( celery.conf.update(
CELERY_RESULT_BACKEND='cache',
CELERY_CACHE_BACKEND=CACHE_URI,
CELERY_TASK_RESULT_EXPIRES=300, CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=( CELERY_QUEUES=(
Queue(HOSTNAME + '.man', Exchange('manager', type='direct'), Queue(HOSTNAME + '.man', Exchange('manager', type='direct'),
......
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