(self, data, priority=None)
| 873 | return conn |
| 874 | |
| 875 | def enqueue(self, data, priority=None): |
| 876 | self.sql('insert into task (queue, data, priority) values (?, ?, ?)', |
| 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: |