Increment retry_count for a task.
(self, task_id: int)
| 278 | self._conn.commit() |
| 279 | |
| 280 | def increment_retry(self, task_id: int): |
| 281 | """Increment retry_count for a task.""" |
| 282 | with self._lock: |
| 283 | self._conn.execute( |
| 284 | "UPDATE task_queue SET retry_count = retry_count + 1 WHERE id = ?", |
| 285 | (task_id,), |
| 286 | ) |
| 287 | self._conn.commit() |
| 288 | |
| 289 | def cancel_task(self, task_id: int) -> bool: |
| 290 | """ |