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

log cluster_id instead of pid

Browse Source
This commit is contained in:
Jason McVetta
2020-02-12 18:26:53 +07:00
parent 14a602ee8b
commit 4529c38067
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/cluster.py
+3 -3
View File
@@ -52,7 +52,7 @@ class Cluster(object):
self.sentinel = Process(target=Sentinel, self.sentinel = Process(target=Sentinel,
args=(self.stop_event, self.start_event, self.cluster_id, self.broker, self.timeout)) args=(self.stop_event, self.start_event, self.cluster_id, self.broker, self.timeout))
self.sentinel.start() self.sentinel.start()
logger.info(_('Q Cluster-{} starting.').format(self.pid)) logger.info(_('Q Cluster-{} starting.').format(self.cluster_id))
while not self.start_event.is_set(): while not self.start_event.is_set():
sleep(0.1) sleep(0.1)
return self.pid return self.pid
@@ -60,10 +60,10 @@ class Cluster(object):
def stop(self): def stop(self):
if not self.sentinel.is_alive(): if not self.sentinel.is_alive():
return False return False
logger.info(_('Q Cluster-{} stopping.').format(self.pid)) logger.info(_('Q Cluster-{} stopping.').format(self.cluster_id))
self.stop_event.set() self.stop_event.set()
self.sentinel.join() self.sentinel.join()
logger.info(_('Q Cluster-{} has stopped.').format(self.pid)) logger.info(_('Q Cluster-{} has stopped.').format(self.cluster_id))
self.start_event = None self.start_event = None
self.stop_event = None self.stop_event = None
return True return True