(self)
| 937 | return [i for i, in self.sql(sql, params, results=True)] |
| 938 | |
| 939 | def flush_schedule(self): |
| 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) ' |