(self, function)
| 1337 | self.server.queue_updated() |
| 1338 | |
| 1339 | def delete_queue_item(self, function): |
| 1340 | with self.mutex: |
| 1341 | for x in range(len(self.queue)): |
| 1342 | if function(self.queue[x]): |
| 1343 | if len(self.queue) == 1: |
| 1344 | self.wipe_queue() |
| 1345 | else: |
| 1346 | self.queue.pop(x) |
| 1347 | heapq.heapify(self.queue) |
| 1348 | self.server.queue_updated() |
| 1349 | return True |
| 1350 | return False |
| 1351 | |
| 1352 | def get_history(self, prompt_id=None, max_items=None, offset=-1, map_function=None): |
| 1353 | with self.mutex: |
no test coverage detected