

@inlineCallbacks
def queueStatusCheck(self):
    (yield self.chan.queue_bind(queue=self.amqp_queue, exchange=self.amqp_exchange))
    queue_status = (yield self.chan.queue_declare(queue=self.amqp_queue, passive=True))
    queue_status.amqp_queue_size = queue_status.fields[1]
    LOGGER.debug(('AMQP queue size: %d' % self.amqp_queue_size))

dataset/ETHPy150Open wehriam/awspider/awspider/servers2/scheduler.py SchedulerServer.queueStatusCheck/VarMisuse@57/73 `self`->`queue_status`