Function runCloudPi

apps/sim/executor/handlers/pi/cloud-backend.ts:183–353

(params, context)

}

export const runCloudPi: PiBackendRun<PiCloudRunParams> = async (params, context) => {
  if (!params.isBYOK) {
    throw new Error(
      'Cloud mode requires your own provider API key (BYOK). Set one in Settings > BYOK.'
    )
  }
  const keyEnvVar = providerApiKeyEnvVar(params.providerId)
  if (!keyEnvVar) {
    throw new Error(
      `Provider "${params.providerId}" is not supported in cloud mode. Use a key-based provider or run in local mode.`
    )
  }

  const branch = params.branchName?.trim() || `pi/${generateShortId(8)}`
  const commitMessage = defaultTitle(params)
  const prompt = buildPiPrompt({
    skills: params.skills,
    initialMessages: params.initialMessages,
    task: params.task,
    guidance: CLOUD_GUIDANCE,
  })
  const totals = createPiTotals()
  const thinking = mapThinkingLevel(params.thinkingLevel) ?? 'medium'

  return withPiSandbox(async (runner) => {
    try {
      const clone = await raceAbort(
        runner.run(CLONE_SCRIPT, {
          envs: {
            GITHUB_TOKEN: params.githubToken,
            REPO_OWNER: params.owner,
            REPO_NAME: params.repo,
            BASE_BRANCH: params.baseBranch?.trim() ?? '',
            BRANCH: branch,
          },
          timeoutMs: CLONE_TIMEOUT_MS,
        }),
        context.signal
      )
      if (clone.exitCode !== 0) {
        throw new Error(
          `git clone failed: ${scrubGitSecrets(clone.stderr || clone.stdout || 'unknown error', params.githubToken)}`
        )
      }
      const baseSha = extractMarkerValues(clone.stdout, '__BASE_SHA__=')[0]
      if (!baseSha) {
        throw new Error('Clone did not report a base commit')
      }
      const detectedBase = extractMarkerValues(clone.stdout, '__DEFAULT_BRANCH__=')[0]

      // Deliver the prompt as a file (read back on Pi's stdin), not a CLI
      // arg/env, so its skill/memory content can't be parsed by the shell that
      // launches the Pi loop.
      await runner.writeFile(PROMPT_PATH, prompt)

      let buffer = ''
      const handleChunk = (chunk: string) => {
        buffer += chunk