@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)
        self.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/original