|
members = self.redis_handler.redis.zrangebyscore(key, 0, current_time, start=0, num=DELAY_ACTION_BATCH_SIZE, withscores=True)
|
|
members = self.redis_handler.redis.zrangebyscore(key, 0, current_time, start=0, num=DELAY_ACTION_BATCH_SIZE, withscores=True)
|
|
# scored_entries = [{"member": entry[0].decode('utf-8'), "score": entry[1]} for entry in members]
|
|
# scored_entries = [{"member": entry[0].decode('utf-8'), "score": entry[1]} for entry in members]
|