Mark a task as running.
(self, task_id: int)
| 251 | return cur.rowcount > 0 |
| 252 | |
| 253 | def start_task(self, task_id: int): |
| 254 | """Mark a task as running.""" |
| 255 | with self._lock: |
| 256 | self._conn.execute( |
| 257 | "UPDATE task_queue SET status = 'running', started_at = ? WHERE id = ?", |
| 258 | (int(time.time()), task_id), |
| 259 | ) |
| 260 | self._conn.commit() |
| 261 | |
| 262 | def complete_task(self, task_id: int, result: str = None): |
| 263 | """Mark a task as completed.""" |
no test coverage detected