Function test_mark_failed

src/context/task_storage.rs:764–789

()

    #[tokio::test]
    async fn test_mark_failed() {
        let ctx = AppContext::builder().build();
        let tsk_env = ctx.tsk_env();
        let db_path = tsk_env.data_dir().join("test_mark_failed.db");
        let storage = TaskStorage::new(db_path).unwrap();

        let task = Task {
            id: "fail1234".to_string(),
            repo_root: tsk_env.data_dir().to_path_buf(),
            branch_name: "tsk/fix/fail-task/fail1234".to_string(),
            copied_repo_path: Some(tsk_env.data_dir().to_path_buf()),
            ..Task::test_default()
        };
        storage.add_task(task).await.unwrap();

        storage.mark_running("fail1234").await.unwrap();
        let updated = storage
            .mark_failed("fail1234", "agent crashed")
            .await
            .unwrap();
        assert_eq!(updated.status, TaskStatus::Failed);
        assert!(updated.completed_at.is_some());
        assert_eq!(updated.error_message, Some("agent crashed".to_string()));
        // started_at should be preserved from mark_running
        assert!(updated.started_at.is_some());
    }

    #[tokio::test]
    async fn test_reset_to_queued() {