def dequeue(self):
        LOGGER.debug('Pending Deuque: %s / Completed Jobs: %d / Queued Jobs: %d / Active Jobs: %d' % (self.pending_dequeue, self.jobs_complete, len(self.job_queue), len(self.active_jobs)))
        if self.amqp_prefetch_count <= len(self.job_queue) and not self.pending_dequeue:
            self.pending_dequeue = True
            LOGGER.debug('Fetching from queue')
            d = self.queue.get()
            d.addCallback(self._dequeueCallback)
            d.addErrback(self._dequeueErrback)
        else:
            reactor.callLater(1, self.dequeue)
dataset/ETHPy150Open wehriam/awspider/awspider/servers2/worker.py/WorkerServer.dequeue/swapped operands of `<=`