mirror of
https://github.com/django-q2/django-q2.git
synced 2026-10-06 04:58:12 +08:00
add UUID4-based cluster_id
This commit is contained in:
@@ -14,6 +14,7 @@ import importlib
|
|||||||
import signal
|
import signal
|
||||||
import socket
|
import socket
|
||||||
import traceback
|
import traceback
|
||||||
|
import uuid
|
||||||
# Django
|
# Django
|
||||||
from django import db
|
from django import db
|
||||||
from django.utils import timezone
|
from django.utils import timezone
|
||||||
@@ -38,6 +39,7 @@ class Cluster(object):
|
|||||||
self.stop_event = None
|
self.stop_event = None
|
||||||
self.start_event = None
|
self.start_event = None
|
||||||
self.pid = current_process().pid
|
self.pid = current_process().pid
|
||||||
|
self.cluster_id = uuid.uuid4()
|
||||||
self.host = socket.gethostname()
|
self.host = socket.gethostname()
|
||||||
self.timeout = Conf.TIMEOUT
|
self.timeout = Conf.TIMEOUT
|
||||||
signal.signal(signal.SIGTERM, self.sig_handler)
|
signal.signal(signal.SIGTERM, self.sig_handler)
|
||||||
|
|||||||
Reference in New Issue
Block a user