From 2e4c1c86ed59877cc029130bc4b826032a04e9a5 Mon Sep 17 00:00:00 2001 From: Ilan Steemers Date: Thu, 3 Sep 2015 15:50:22 +0200 Subject: [PATCH] Adds extra AUTH before PING --- django_q/brokers/disque.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/django_q/brokers/disque.py b/django_q/brokers/disque.py index bbeb7d7..4ba7ee9 100644 --- a/django_q/brokers/disque.py +++ b/django_q/brokers/disque.py @@ -23,6 +23,8 @@ class Disque(Broker): return self.connection.execute_command('ACKJOB {}'.format(task_id)) def ping(self): + if Conf.DISQUE_AUTH: + self.connection.execute_command('AUTH {}'.format(Conf.DISQUE_AUTH)) return self.connection.execute_command('HELLO')[0] > 0 def delete(self, task_id):