From 31e4886b8356ad294a7843d5d98b56136fa0fac8 Mon Sep 17 00:00:00 2001
From: Bach Dániel <bd@ik.bme.hu>
Date: Fri, 27 Feb 2015 16:50:43 +0100
Subject: [PATCH] manager: change celery result backend
Closes #380
---
circle/manager/mancelery.py | 4 +---
circle/manager/moncelery.py | 4 +---
circle/manager/slowcelery.py | 4 +---
3 files changed, 3 insertions(+), 9 deletions(-)
diff --git a/circle/manager/mancelery.py b/circle/manager/mancelery.py
index ab095fb..63fc528 100755
--- a/circle/manager/mancelery.py
+++ b/circle/manager/mancelery.py
@@ -22,7 +22,6 @@ from kombu import Queue, Exchange
from os import getenv
HOSTNAME = "localhost"
-CACHE_URI = getenv("CACHE_URI", "pylibmc://127.0.0.1:11211/")
QUEUE_NAME = HOSTNAME + '.man'
@@ -38,8 +37,7 @@ celery = Celery('manager',
])
celery.conf.update(
- CELERY_RESULT_BACKEND='cache',
- CELERY_CACHE_BACKEND=CACHE_URI,
+ CELERY_RESULT_BACKEND='amqp',
CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=(
Queue(HOSTNAME + '.man', Exchange('manager', type='direct'),
diff --git a/circle/manager/moncelery.py b/circle/manager/moncelery.py
index 1ff01c1..646c6f9 100755
--- a/circle/manager/moncelery.py
+++ b/circle/manager/moncelery.py
@@ -22,7 +22,6 @@ from kombu import Queue, Exchange
from os import getenv
HOSTNAME = "localhost"
-CACHE_URI = getenv("CACHE_URI", "pylibmc://127.0.0.1:11211/")
QUEUE_NAME = HOSTNAME + '.monitor'
celery = Celery('monitor',
@@ -32,8 +31,7 @@ celery = Celery('monitor',
])
celery.conf.update(
- CELERY_RESULT_BACKEND='cache',
- CELERY_CACHE_BACKEND=CACHE_URI,
+ CELERY_RESULT_BACKEND='amqp',
CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=(
Queue(QUEUE_NAME, Exchange('monitor', type='direct'),
diff --git a/circle/manager/slowcelery.py b/circle/manager/slowcelery.py
index c06d7d5..ce59ec6 100755
--- a/circle/manager/slowcelery.py
+++ b/circle/manager/slowcelery.py
@@ -22,7 +22,6 @@ from kombu import Queue, Exchange
from os import getenv
HOSTNAME = "localhost"
-CACHE_URI = getenv("CACHE_URI", "pylibmc://127.0.0.1:11211/")
QUEUE_NAME = HOSTNAME + '.man.slow'
celery = Celery('manager.slow',
@@ -34,8 +33,7 @@ celery = Celery('manager.slow',
])
celery.conf.update(
- CELERY_RESULT_BACKEND='cache',
- CELERY_CACHE_BACKEND=CACHE_URI,
+ CELERY_RESULT_BACKEND='amqp',
CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=(
Queue(QUEUE_NAME, Exchange('manager.slow', type='direct'),
--
libgit2 0.26.0