From 4d905c6aaad04e33eb844f4f8d3d7e5133ca64cc Mon Sep 17 00:00:00 2001 From: Rick Elrod Date: Wed, 4 Sep 2019 17:05:11 +0000 Subject: [PATCH] basset/worker: hotfix for new pika (this has been in prod for a while now, just not ansiblized) Signed-off-by: Rick Elrod --- roles/basset/worker/files/basset-worker | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/roles/basset/worker/files/basset-worker b/roles/basset/worker/files/basset-worker index 62e63d7236..57026f9e28 100644 --- a/roles/basset/worker/files/basset-worker +++ b/roles/basset/worker/files/basset-worker @@ -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')