Changes Disque ping to hello

This commit is contained in:
Ilan Steemers
2015-09-03 15:13:44 +02:00
parent a342aaf009
commit 453fc3b133
+1 -1
View File
@@ -23,7 +23,7 @@ class Disque(Broker):
return self.connection.execute_command('ACKJOB {}'.format(task_id))
def ping(self):
return self.connection.execute_command('HELLO')[0] > 0e
return self.connection.execute_command('HELLO')[0] > 0
def delete(self, task_id):
return self.connection.execute_command('DELJOB {}'.format(task_id))