(self, key, value, is_result=False)
| 940 | self.sql('delete from schedule where queue = ?', (self.name,), True) |
| 941 | |
| 942 | def put_data(self, key, value, is_result=False): |
| 943 | self.sql('insert or replace into kv (queue, key, value) ' |
| 944 | 'values (?, ?, ?)', |
| 945 | (self.name, key, self.to_blob(value)), True) |
| 946 | |
| 947 | def peek_data(self, key): |
| 948 | res = self.sql('select value from kv where queue = ? and key = ?', |