(self)
| 545 | return self.conn.zrange(self.schedule_key, 0, limit, withscores=False) |
| 546 | |
| 547 | def flush_schedule(self): |
| 548 | self.conn.delete(self.schedule_key) |
| 549 | |
| 550 | def put_data(self, key, value, is_result=False): |
| 551 | self.conn.hset(self.result_key, key, value) |