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

tuning timeout

Browse Source
This commit is contained in:
Ilan Steemers
2015-07-22 14:25:32 +02:00
parent f6cbd9817a
commit a26ffbf03b
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/cluster.py
+4 -4
View File
@@ -226,18 +226,18 @@ class Sentinel(object):
logger.info(_('Q Cluster-{} running.').format(self.parent_pid)) logger.info(_('Q Cluster-{} running.').format(self.parent_pid))
scheduler(list_key=self.list_key) scheduler(list_key=self.list_key)
counter = 0 counter = 0
cycle = 0.5 cycle = 0.5 # guard loop sleep in seconds
# Guard loop. Runs at least once # Guard loop. Runs at least once
while not self.stop_event.is_set() or not counter: while not self.stop_event.is_set() or not counter:
# Check Workers # Check Workers
for p in self.pool: for p in self.pool:
# Are you alive? # Are you alive?
if not p.is_alive() or (self.timeout and int(p.timer.value) == 0): if not p.is_alive() or (self.timeout and p.timer.value == 0):
self.reincarnate(p) self.reincarnate(p)
continue continue
# Decrement timer if work is being done # Decrement timer if work is being done
if p.timer.value > 0: if self.timeout and p.timer.value > 0:
p.timer.value -= cycle p.timer.value -= cycle
# Check Monitor # Check Monitor
if not self.monitor.is_alive(): if not self.monitor.is_alive():
self.reincarnate(self.monitor) self.reincarnate(self.monitor)