Method complete_task

core/state.py:262–269

Mark a task as completed.

(self, task_id: int, result: str = None)

            self._conn.commit()

    def complete_task(self, task_id: int, result: str = None):
        """Mark a task as completed."""
        with self._lock:
            self._conn.execute(
                "UPDATE task_queue SET status = 'done', result = ?, completed_at = ? WHERE id = ?",
                (result, int(time.time()), task_id),
            )
            self._conn.commit()

    def fail_task(self, task_id: int, error: str):
        """Mark a task as failed."""