(self)
| 888 | return data |
| 889 | |
| 890 | def queue_size(self): |
| 891 | return self.sql('select count(id) from task where queue=?', |
| 892 | (self.name,), results=True)[0][0] |
| 893 | |
| 894 | def enqueued_items(self, limit=None): |
| 895 | sql = 'select data from task where queue=? order by priority desc, id' |