Function cancelQueuedTaskSync

packages/db/src/task-queue.ts:610–660

(input: {
  taskId: string;
  errorText?: string;
})

}

export function cancelQueuedTaskSync(input: {
  taskId: string;
  errorText?: string;
}): QueuedTaskRecord {
  const db = getDatabase();
  const now = new Date().toISOString();
  const previous = readQueuedTaskSync(input.taskId);
  db.prepare(
    `UPDATE agent_task_queue
     SET status = 'cancelled',
         error_text = COALESCE(?, error_text),
         finished_at = ?,
         updated_at = ?
     WHERE id = ? AND status = 'queued'`,
  ).run(input.errorText ?? null, now, now, input.taskId);

  const task = readQueuedTaskSync(input.taskId);
  if (!task) {
    throw new Error(`Queued task "${input.taskId}" does not exist.`);
  }
  if (previous?.status !== "cancelled" && task.status === "cancelled") {
    const attempt = readLatestAgentTaskAttemptForTaskSync(task.id);
    if (attempt) {
      updateAgentTaskAttemptSync({
        attemptId: attempt.id,
        status: "cancelled",
        errorText: input.errorText ?? "Task cancelled.",
      });
    }
    const runtime = readAgentRuntimeSync(task.runtimeId);
    recordRouterLifecycleEvent(task, {
      attemptId: attempt?.id,
      type: "cancelled",
      actorType: "system",
      runtimeId: task.runtimeId,
      provider: runtime?.provider,
      summary: input.errorText ? truncateSummary(input.errorText) : "Task cancelled before execution.",
      data: {
        attemptId: attempt?.id,
      },
    });
    recordQueueLifecycleEvent(task, {
      type: "cancelled",
      title: "Task cancelled",
      summary: input.errorText ? truncateSummary(input.errorText) : "The queued task was cancelled before execution.",
      severity: input.errorText ? "warning" : "info",
      status: "failed",
    });
  }
  return task;
}

function recordQueueLifecycleEvent(
  task: QueuedTaskRecord,