

def enqueue(self, task):
    retry = (Conf.RETRY if (Conf.RETRY > 0) else '{} REPLICATE 1'.format(Conf.RETRY))
    return self.connection.execute_command('ADDJOB {} {} 500 RETRY {}'.format(self.list_key, task, retry)).decode()

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