Skip to content

CIRCLE / vmdriver

Go to a project
Commit 0cc1f1e3 by Guba Sándor
Options

netcelery: updated to cache backend

parent 547d0617
Showing with 3 additions and 2 deletions
netcelery.py
...@@ -4,13 +4,14 @@ from socket import gethostname ...@@ -4,13 +4,14 @@ from socket import gethostname
from os import getenv from os import getenv
HOSTNAME = gethostname() HOSTNAME = gethostname()
AMQP_URI = getenv('AMQP_URI') AMQP_URI = getenv('AMQP_URI')
CACHE_URI = getenv('CACHE_URI')
celery = Celery('netdriver', backend='cache',
celery = Celery('netdriver', backend='amqp',
broker=AMQP_URI, broker=AMQP_URI,
include=['netdriver']) include=['netdriver'])
celery.conf.update( celery.conf.update(
CELERY_CACHE_BACKEND=CACHE_URI,
CELERY_TASK_RESULT_EXPIRES=300, CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=( CELERY_QUEUES=(
Queue(HOSTNAME + '.net', Exchange( Queue(HOSTNAME + '.net', Exchange(
......
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