

def dequeue(self):
    tasks = self.connection.execute_command('GETJOB COUNT {} TIMEOUT 1000 FROM {}'.format(Conf.BULK, self.list_key))
    if tasks:
        return [(t[1].decode(), t[2].decode()) for t in tasks]

dataset/ETHPy150Open Koed00/django-q/django_q/brokers/disque.py Disque.dequeue/original