From 6bca848f5b272149bb32353a62f9d37108fcbe15 Mon Sep 17 00:00:00 2001 From: Chenjun Shen <chenjun.shen@gmail.com> Date: Tue, 29 Oct 2019 09:03:33 +0100 Subject: [PATCH] Remove unused variable WAKE_UP Change-Id: I65f57973b66f353a1e6fef3d0bf7793f821c1c5c Closes-Bug: 1850259 --- oslo_messaging/_drivers/amqpdriver.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/oslo_messaging/_drivers/amqpdriver.py b/oslo_messaging/_drivers/amqpdriver.py index f5c599743..ccab0ce07 100644 --- a/oslo_messaging/_drivers/amqpdriver.py +++ b/oslo_messaging/_drivers/amqpdriver.py @@ -44,6 +44,7 @@ class MessageOperationsHandler(object): serialized and run in the same thread, since underlying drivers like kombu are not thread safe. """ + def __init__(self, name): self.name = "%s (%s)" % (name, hex(id(self))) self._tasks = moves.queue.Queue() @@ -386,8 +387,6 @@ class NotificationAMQPListener(AMQPListener): class ReplyWaiters(object): - WAKE_UP = object() - def __init__(self): self._queues = {} self._wrn_threshold = 10