| 877 | (self.name, self.to_blob(data), priority or 0), commit=True) |
| 878 | |
| 879 | def dequeue(self): |
| 880 | with self.db(commit=True) as curs: |
| 881 | curs.execute('select id, data from task where queue = ? ' |
| 882 | 'order by priority desc, id limit 1', (self.name,)) |
| 883 | result = curs.fetchone() |
| 884 | if result is not None: |
| 885 | tid, data = result |
| 886 | curs.execute('delete from task where id = ?', (tid,)) |
| 887 | if curs.rowcount == 1: |
| 888 | return data |
| 889 | |
| 890 | def queue_size(self): |
| 891 | return self.sql('select count(id) from task where queue=?', |