fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-04 17:58:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Disque: If retry is 0 , explicitly set replicate to 1

Browse Source
This commit is contained in:
Ilan Steemers
2015-09-03 14:41:03 +02:00
parent c626c3137c
commit 653ae80477
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/brokers/disque.py
+2 -1
View File
@@ -7,8 +7,9 @@ from django_q.conf import Conf
class Disque(Broker): class Disque(Broker):
def enqueue(self, task): def enqueue(self, task):
retry = Conf.RETRY if Conf.RETRY > 0 else '{} REPLICATE 1'.format(Conf.RETRY)
return self.connection.execute_command( return self.connection.execute_command(
'ADDJOB {} {} 500 RETRY {}'.format(self.list_key, task, Conf.RETRY)).decode() 'ADDJOB {} {} 500 RETRY {}'.format(self.list_key, task, retry)).decode()
def dequeue(self): def dequeue(self):
task = self.connection.execute_command('GETJOB TIMEOUT 1000 FROM {}'.format(self.list_key)) task = self.connection.execute_command('GETJOB TIMEOUT 1000 FROM {}'.format(self.list_key))