Function readQueuedTaskSync

packages/db/src/task-queue.ts:210–243

(taskId: string)

}

export function readQueuedTaskSync(taskId: string): QueuedTaskRecord | null {
  const db = getDatabase();
  const row = db
    .prepare(
      `SELECT
        id,
        workspace_id AS workspaceId,
        agent_id AS agentId,
        runtime_id AS runtimeId,
        router_session_id AS routerSessionId,
        issue_id AS issueId,
        trigger_type AS triggerType,
        priority,
        status,
        input_json AS inputJson,
        requested_by_user_id AS requestedByUserId,
        requested_by_display_name AS requestedByDisplayName,
        result_json AS resultJson,
        error_text AS errorText,
        session_id AS sessionId,
        work_dir AS workDir,
        queued_at AS queuedAt,
        claimed_at AS claimedAt,
        started_at AS startedAt,
        finished_at AS finishedAt,
        created_at AS createdAt,
        updated_at AS updatedAt
      FROM agent_task_queue
      WHERE id = ?`,
    )
    .get(taskId) as Record<string, unknown> | undefined;

  return row ? mapQueuedTaskRecord(row) : null;
}

export function claimNextQueuedTaskForRuntimeSync(runtimeId: string, workspaceId?: string): QueuedTaskRecord | null {
  const db = getDatabase();