tab removal
This commit is contained in:
@@ -69,7 +69,7 @@ nova_queues = [
|
|||||||
class SchedulerFanoutConsumer(kombu.mixins.ConsumerMixin):
|
class SchedulerFanoutConsumer(kombu.mixins.ConsumerMixin):
|
||||||
def __init__(self, connection, url):
|
def __init__(self, connection, url):
|
||||||
self.connection = connection
|
self.connection = connection
|
||||||
self.url = url
|
self.url = url
|
||||||
|
|
||||||
def get_consumers(self, Consumer, channel):
|
def get_consumers(self, Consumer, channel):
|
||||||
return [Consumer(queues=scheduler_queues,
|
return [Consumer(queues=scheduler_queues,
|
||||||
|
Reference in New Issue
Block a user