Method fail_task

core/planner_v2.py:228–267

Mark a task as failed, with retry logic. If retries remain, sets task back to pending.

(self, task_id: int, error_msg: str)

        return True
    
    def fail_task(self, task_id: int, error_msg: str) -> bool:
        """
        Mark a task as failed, with retry logic.

        If retries remain, sets task back to pending.
        """
        task = self._tasks.get(task_id)
        if not task:
            return False

        task.retry_count += 1
        self.state.increment_retry(task_id)

        if task.retry_count < self.max_retries:
            # Retry - set back to pending
            task.status = TaskStatus.PENDING
            task.error = f"Retry {task.retry_count}/{self.max_retries}: {error_msg}"
            self.state.execute(
                "UPDATE task_queue SET status = 'pending' WHERE id = ?", (task_id,)
            )
            warning(f"Planner: task {task_id} failed, retrying ({task.retry_count}/{self.max_retries})")
        else:
            # Max retries reached - mark as failed
            task.status = TaskStatus.FAILED
            task.error = error_msg
            task.completed_at = int(time.time())

            # Update database
            self.state.fail_task(task_id, error_msg)

            error(f"Planner: task {task_id} failed permanently: {error_msg}")

            # Log in episodic memory
            self.state.log_action("task_failed", f"Task {task_id}: {error_msg[:200]}")

        # Clear current task
        if self._current_task and self._current_task.id == task_id:
            self._current_task = None

        return True

    def adapt(self, task_id: int, error_msg: str) -> Optional[str]:
        """