debug

src/core/callcenter/cache.py

@@ -133,13 +133,13 @@ class Cache:
         members = self.redis_handler.redis.zrangebyscore(key, 0, current_time, start=0, num=DELAY_ACTION_BATCH_SIZE, withscores=True)
         if not members:
             return []
-        self.logger.info('get_delay_message %s %s %s'%(key, action, members))
+        print('get_delay_message %s %s %s'%(key, action, members), flush=True)
         # 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)))
+        print('get_delay_message %s %s %s'%(key, action, json.dumps(action_list)), flush=True)
         if 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))
+            print('get_delay_message %s %s %s %s'%(key, action, json.dumps(action_list), a), flush=True)
         return action_list
 
     def lock_delay_action(self, val):