Commit d04f15e2 by Bach Dániel

change celery result backend

parent 29a998c7
...@@ -77,7 +77,6 @@ Save configuration to virtualenv and activate environment:: ...@@ -77,7 +77,6 @@ Save configuration to virtualenv and activate environment::
export LIBVIRT_URI=test:///default export LIBVIRT_URI=test:///default
export AMQP_URI=amqp://cloud:password@$(hostname)/circle export AMQP_URI=amqp://cloud:password@$(hostname)/circle
export HYPERVISOR_TYPE=test export HYPERVISOR_TYPE=test
export CACHE_URI=pylibmc://$(hostname):11211/
END END
Copy the libvrit bindings to the local virtualenv directory:: Copy the libvrit bindings to the local virtualenv directory::
......
...@@ -17,7 +17,6 @@ if HOSTNAME is None: ...@@ -17,7 +17,6 @@ if HOSTNAME is None:
"Hostname format must be hostname.module.priority.") "Hostname format must be hostname.module.priority.")
AMQP_URI = getenv('AMQP_URI') AMQP_URI = getenv('AMQP_URI')
CACHE_URI = getenv('CACHE_URI')
def to_bool(value): def to_bool(value):
...@@ -37,8 +36,7 @@ celery = Celery('netcelery', ...@@ -37,8 +36,7 @@ celery = Celery('netcelery',
include=['netdriver']) include=['netdriver'])
celery.conf.update( celery.conf.update(
CELERY_RESULT_BACKEND='cache', CELERY_RESULT_BACKEND='amqp',
CELERY_CACHE_BACKEND=CACHE_URI,
CELERY_TASK_RESULT_EXPIRES=300, CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=( CELERY_QUEUES=(
Queue(HOSTNAME, Exchange( Queue(HOSTNAME, Exchange(
......
...@@ -24,7 +24,6 @@ else: ...@@ -24,7 +24,6 @@ else:
"Hostname format must be hostname.module.priority.") "Hostname format must be hostname.module.priority.")
AMQP_URI = getenv('AMQP_URI') AMQP_URI = getenv('AMQP_URI')
CACHE_URI = getenv('CACHE_URI')
# Global configuration parameters declaration # Global configuration parameters declaration
...@@ -42,8 +41,7 @@ celery = Celery('vmcelery', ...@@ -42,8 +41,7 @@ celery = Celery('vmcelery',
include=['vmdriver']) include=['vmdriver'])
celery.conf.update( celery.conf.update(
CELERY_RESULT_BACKEND='cache', CELERY_RESULT_BACKEND='amqp',
CELERY_CACHE_BACKEND=CACHE_URI,
CELERY_TASK_RESULT_EXPIRES=300, CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=( CELERY_QUEUES=(
Queue(HOSTNAME, Exchange( Queue(HOSTNAME, 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