diff --git a/django_q/cluster.py b/django_q/cluster.py index ce4b0ba..bf2f821 100644 --- a/django_q/cluster.py +++ b/django_q/cluster.py @@ -49,7 +49,6 @@ class Cluster(object): self.sentinel = None self.stop_event = None self.start_event = None - self.stopped_event = None self.pid = current_process().pid self.host = socket.gethostname() self.list_key = list_key @@ -111,10 +110,6 @@ class Cluster(object): def has_stopped(self): return self.start_event is None and self.stop_event is None and self.sentinel - @property - def is_idle(self): - return self.sentinel is None - class Sentinel(object): def __init__(self, stop_event, start_event, list_key=Conf.Q_LIST, timeout=Conf.TIMEOUT, start=True): diff --git a/django_q/tests/test_cluster.py b/django_q/tests/test_cluster.py index 2d62eec..1e0f65f 100644 --- a/django_q/tests/test_cluster.py +++ b/django_q/tests/test_cluster.py @@ -39,7 +39,6 @@ def test_cluster_initial(r): r.delete(list_key) c = Cluster(list_key=list_key) assert c.sentinel is None - assert c.is_idle assert c.start() > 0 assert c.sentinel.is_alive() is True assert c.is_running