From 4529c3806799f8b37cb9d0bfd489cccfe6db427b Mon Sep 17 00:00:00 2001 From: Jason McVetta Date: Wed, 12 Feb 2020 18:26:53 +0700 Subject: [PATCH] log cluster_id instead of pid --- django_q/cluster.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/django_q/cluster.py b/django_q/cluster.py index 4e755c1..bece2df 100644 --- a/django_q/cluster.py +++ b/django_q/cluster.py @@ -52,7 +52,7 @@ class Cluster(object): self.sentinel = Process(target=Sentinel, args=(self.stop_event, self.start_event, self.cluster_id, self.broker, self.timeout)) 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(): sleep(0.1) return self.pid @@ -60,10 +60,10 @@ class Cluster(object): def stop(self): if not self.sentinel.is_alive(): return False - logger.info(_('Q Cluster-{} stopping.').format(self.pid)) + logger.info(_('Q Cluster-{} stopping.').format(self.cluster_id)) self.stop_event.set() 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.stop_event = None return True