infrastructure/ansible
1
0
Fork 0
Code Pull requests 7 Activity Actions

basset/worker: hotfix for new pika (this has been in prod for a while now, just not ansiblized)

Browse source 
Signed-off-by: Rick Elrod <relrod@redhat.com>
This commit is contained in:
Rick Elrod 2019-09-04 17:05:11 +00:00 • committed by Pierre-Yves Chibon
parent a3db2ba114
commit 4d905c6aaa
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
roles/basset/worker/files/basset-worker
View file

@ -153,7 +153,8 @@ def callback(ch, method, properties, body):
# Make sure we leave any other messages in the queue
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback, queue='check_submission')
channel.basic_consume('check_submission', callback)
# queue='check_submission')
try:
log.debug('Starting consuming')