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

Makes DB polling time configurable via poll setting

Browse Source
This commit is contained in:
Ilan Steemers
2016-01-26 22:29:00 +01:00
parent 9baf1b6394
commit af3b1da08f
3 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/brokers/mongo.py
+1 -1
View File
@@ -61,7 +61,7 @@ class Mongo(Broker):
if task: if task:
return [(str(task['_id']), task['payload'])] return [(str(task['_id']), task['payload'])]
# empty queue, spare the cpu # empty queue, spare the cpu
sleep(0.2) sleep(Conf.POLL)
def delete_queue(self): def delete_queue(self):
return self.collection.drop() return self.collection.drop()
django_q/brokers/orm.py
+1 -1
View File
@@ -61,7 +61,7 @@ class ORM(Broker):
task_list.append((task.pk, task.payload)) task_list.append((task.pk, task.payload))
return task_list return task_list
# empty queue, spare the cpu # empty queue, spare the cpu
sleep(0.2) sleep(Conf.POLL)
def delete_queue(self): def delete_queue(self):
return self.purge_queue() return self.purge_queue()
django_q/conf.py
+3
View File
@@ -50,6 +50,9 @@ class Conf(object):
# ORM broker # ORM broker
ORM = conf.get('orm', None) ORM = conf.get('orm', None)
# Database Poll
POLL = conf.get('poll', 0.2)
# MongoDB broker # MongoDB broker
MONGO = conf.get('mongo', None) MONGO = conf.get('mongo', None)
MONGO_DB = conf.get('mongo_db', None) MONGO_DB = conf.get('mongo_db', None)