From af3b1da08f79b3b6a7820b2c34a9efe3ea5495fc Mon Sep 17 00:00:00 2001 From: Ilan Steemers Date: Tue, 26 Jan 2016 22:29:00 +0100 Subject: [PATCH] Makes DB polling time configurable via `poll` setting --- django_q/brokers/mongo.py | 2 +- django_q/brokers/orm.py | 2 +- django_q/conf.py | 3 +++ 3 files changed, 5 insertions(+), 2 deletions(-) diff --git a/django_q/brokers/mongo.py b/django_q/brokers/mongo.py index dfce5ba..a1235e7 100644 --- a/django_q/brokers/mongo.py +++ b/django_q/brokers/mongo.py @@ -61,7 +61,7 @@ class Mongo(Broker): if task: return [(str(task['_id']), task['payload'])] # empty queue, spare the cpu - sleep(0.2) + sleep(Conf.POLL) def delete_queue(self): return self.collection.drop() diff --git a/django_q/brokers/orm.py b/django_q/brokers/orm.py index 0e65863..a0db3a9 100644 --- a/django_q/brokers/orm.py +++ b/django_q/brokers/orm.py @@ -61,7 +61,7 @@ class ORM(Broker): task_list.append((task.pk, task.payload)) return task_list # empty queue, spare the cpu - sleep(0.2) + sleep(Conf.POLL) def delete_queue(self): return self.purge_queue() diff --git a/django_q/conf.py b/django_q/conf.py index ae8d022..58989d4 100644 --- a/django_q/conf.py +++ b/django_q/conf.py @@ -50,6 +50,9 @@ class Conf(object): # ORM broker ORM = conf.get('orm', None) + # Database Poll + POLL = conf.get('poll', 0.2) + # MongoDB broker MONGO = conf.get('mongo', None) MONGO_DB = conf.get('mongo_db', None)