|
@@ -136,8 +136,10 @@ class Cache:
|
|
|
self.logger.info('get_delay_message %s %s %s'%(key, action, members))
|
|
|
# scored_entries = [{"member": entry[0].decode('utf-8'), "score": entry[1]} for entry in members]
|
|
|
action_list = [entry[0].decode('utf-8') for entry in members]
|
|
|
+ self.logger.info('get_delay_message %s %s %s'%(key, action, json.dumps(action_list)))
|
|
|
if action_list:
|
|
|
- self.redis_handler.redis.zrem(key, *action_list)
|
|
|
+ a = self.redis_handler.redis.zrem(key, *action_list)
|
|
|
+ self.logger.info('get_delay_message %s %s %s %s'%(key, action, json.dumps(action_list), a))
|
|
|
return action_list
|
|
|
|
|
|
def lock_delay_action(self, val):
|