(self, key, value, is_result=False)
| 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) |
| 552 | if is_result and self.notify_result: |
| 553 | nkey = self.notify_prefix + key |
| 554 | pipe = self.conn.pipeline() |
| 555 | pipe.lpush(nkey, b'1') |
| 556 | pipe.expire(nkey, self.notify_result_ttl) |
| 557 | pipe.execute() |
| 558 | |
| 559 | def peek_data(self, key): |
| 560 | pipe = self.conn.pipeline() |