

def delete_queue(self):
    jobs = self.connection.execute_command('JSCAN QUEUE {}'.format(self.list_key))[1]
    if jobs:
        job_ids = ' '.join((jid.decode() for jid in jid))
        self.connection.execute_command('DELJOB {}'.format(job_ids))
    return len(jobs)

dataset/ETHPy150Open Koed00/django-q/django_q/brokers/disque.py Disque.delete_queue/VarMisuse@51/66 `jobs`->`jid`