diff --git a/django_q/brokers/disque.py b/django_q/brokers/disque.py index 89d7729..30c0358 100644 --- a/django_q/brokers/disque.py +++ b/django_q/brokers/disque.py @@ -23,7 +23,7 @@ class Disque(Broker): return self.connection.execute_command('ACKJOB {}'.format(task_id)) def ping(self): - return self.connection.ping() + return self.connection.execute_command('HELLO')[0] == 1 def delete(self, task_id): return self.connection.execute_command('DELJOB {}'.format(task_id))