Function selectQueuedTaskForRuntime

packages/db/src/task-queue.ts:835–850

(
  db: ReturnType<typeof getDatabase>,
  runtimeId: string,
  workspaceId?: string,
)

}

function selectQueuedTaskForRuntime(
  db: ReturnType<typeof getDatabase>,
  runtimeId: string,
  workspaceId?: string,
): Record<string, unknown> | undefined {
  return db
    .prepare(
      `SELECT id
       FROM agent_task_queue
       WHERE runtime_id = ? AND status = 'queued'
       ${typeof workspaceId === "string" ? "AND workspace_id = ?" : ""}
       ORDER BY priority DESC, created_at ASC
       LIMIT 1`,
    )
    .get(...(typeof workspaceId === "string" ? [runtimeId, workspaceId] : [runtimeId])) as Record<string, unknown> | undefined;
}

function selectFallbackQueuedTaskForRuntime(
  db: ReturnType<typeof getDatabase>,