Function process_one_task

crates/backend/src/comment_worker.rs:178–359

(
    store: Arc<CommentDataStore>,
    config: CommentAiWorkerConfig,
    task_id: &str,
)

}

async fn process_one_task(
    store: Arc<CommentDataStore>,
    config: CommentAiWorkerConfig,
    task_id: &str,
) -> Result<()> {
    let mut task = match store.get_comment_task(task_id).await? {
        Some(task) => task,
        None => {
            tracing::warn!("comment worker skipped missing task {task_id}");
            return Ok(());
        },
    };

    if task.status == COMMENT_STATUS_REJECTED || task.status == COMMENT_STATUS_DONE {
        tracing::info!("comment worker skipped finalized task {task_id}");
        return Ok(());
    }

    if task.status == COMMENT_STATUS_APPROVED {
        let transitioned = store
            .transition_comment_task(task_id, COMMENT_STATUS_RUNNING, None, None, true)
            .await?;
        if let Some(updated) = transitioned {
            task = updated;
        }
    } else if task.status != COMMENT_STATUS_RUNNING {
        tracing::warn!("comment worker skipped task {} with status {}", task.task_id, task.status);
        return Ok(());
    }

    let run_id = generate_ai_run_id(&task.task_id);
    let run_created = store
        .create_ai_run(NewCommentAiRunInput {
            run_id: run_id.clone(),
            task_id: task.task_id.clone(),
            runner_program: config.runner_program.clone(),
            runner_args_json: serde_json::to_string(&config.runner_args).unwrap_or_default(),
            skill_path: config.skill_path.display().to_string(),
        })
        .await;
    if let Err(err) = run_created {
        let reason = format!("failed to create comment ai run record: {err}");
        mark_task_failed(store.as_ref(), task_id, reason).await;
        return Ok(());
    }

    let run_output = match run_ai_runner(store.clone(), &config, &task, &run_id).await {
        Ok(output) => output,
        Err(err) => {
            let reason = err.to_string();
            let _ = store
                .finalize_ai_run(
                    &run_id,
                    COMMENT_AI_RUN_STATUS_FAILED,
                    None,
                    Some(reason.clone()),
                    None,
                )