From 06b33da709a9350dba85a715be3264501e272bbc Mon Sep 17 00:00:00 2001 From: Tim Abbott Date: Sun, 27 Mar 2016 23:16:57 -0700 Subject: [PATCH] process_queue: Fix missing worker.setup() in single-threaded codepath. --- zerver/management/commands/process_queue.py | 1 + 1 file changed, 1 insertion(+) diff --git a/zerver/management/commands/process_queue.py b/zerver/management/commands/process_queue.py index 32b37a148a..8bcdb82a7b 100644 --- a/zerver/management/commands/process_queue.py +++ b/zerver/management/commands/process_queue.py @@ -38,6 +38,7 @@ class Command(BaseCommand): logger.info("Worker %d connecting to queue %s" % (worker_num, queue_name)) worker = get_worker(queue_name) + worker.setup() def signal_handler(signal, frame): logger.info("Worker %d disconnecting from queue %s" % (worker_num, queue_name))