From ea30c1d43f210a85d522968f75170b5b73fd7c91 Mon Sep 17 00:00:00 2001 From: Jason McVetta Date: Wed, 12 Feb 2020 17:41:10 +0700 Subject: [PATCH] add UUID4-based cluster_id --- django_q/cluster.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/django_q/cluster.py b/django_q/cluster.py index 860527c..30cb626 100644 --- a/django_q/cluster.py +++ b/django_q/cluster.py @@ -14,6 +14,7 @@ import importlib import signal import socket import traceback +import uuid # Django from django import db from django.utils import timezone @@ -38,6 +39,7 @@ class Cluster(object): self.stop_event = None self.start_event = None self.pid = current_process().pid + self.cluster_id = uuid.uuid4() self.host = socket.gethostname() self.timeout = Conf.TIMEOUT signal.signal(signal.SIGTERM, self.sig_handler)