(self)
| 99 | self.pending_events.append(event) |
| 100 | |
| 101 | def _process(self): |
| 102 | conn = sqlite3.connect(self.db) |
| 103 | conn.row_factory = sqlite3.Row |
| 104 | with conn: |
| 105 | while self.running: |
| 106 | f = self.tasks.get(True) |
| 107 | try: |
| 108 | while True: |
| 109 | f(conn) |
| 110 | f = self.tasks.get(False) |
| 111 | except queue.Empty: |
| 112 | pass |
| 113 | conn.commit() |
| 114 | for event in self.pending_events: |
| 115 | self.injector.trigger(event) |
| 116 | self.pending_events = [] |
| 117 | self.injector.close() |