Skip to content

Gelencsér Szabolcs / vmdriver

Go to a project
Commit 4608a6ef by Bach Dániel
Options

fix flake8 warnings

parent 5ea57598
Showing with 4 additions and 4 deletions
netcelery.py
...@@ -11,7 +11,7 @@ celery = Celery('netdriver', backend='amqp', ...@@ -11,7 +11,7 @@ celery = Celery('netdriver', backend='amqp',
include=['netdriver']) include=['netdriver'])
celery.conf.update( celery.conf.update(
CELERY_TASK_RESULT_EXPIRES = 300, CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=( CELERY_QUEUES=(
Queue(HOSTNAME + '.net', Exchange( Queue(HOSTNAME + '.net', Exchange(
'netdriver', type='direct'), routing_key='netdriver'), 'netdriver', type='direct'), routing_key='netdriver'),
......
vmcelery.py
...@@ -16,12 +16,12 @@ celery = Celery('vmcelery', backend='amqp', ...@@ -16,12 +16,12 @@ celery = Celery('vmcelery', backend='amqp',
include=['vmdriver']) include=['vmdriver'])
celery.conf.update( celery.conf.update(
CELERY_TASK_RESULT_EXPIRES = 300, CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=( CELERY_QUEUES=(
Queue(HOSTNAME + '.vm', Exchange( Queue(HOSTNAME + '.vm', Exchange(
'vmdriver', type='direct'), routing_key="vmdriver"), 'vmdriver', type='direct'), routing_key="vmdriver"),
# Queue(HOSTNAME + '.monitor', Exchange( # Queue(HOSTNAME + '.monitor', Exchange(
# 'monitor', type='direct'), routing_key="monitor"), # 'monitor', type='direct'), routing_key="monitor"),
) )
) )
......
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