Function createAutonomyRunCore

src/utils/autonomyRuns.ts:484–505

(
  params: CreateAutonomyRunParams,
  skipIfActiveSource: boolean,
)

}

async function createAutonomyRunCore(
  params: CreateAutonomyRunParams,
  skipIfActiveSource: boolean,
): Promise<AutonomyRunRecord | null> {
  const rootDir = resolve(params.rootDir ?? getProjectRoot())
  const currentDir = resolve(params.currentDir ?? rootDir)
  const record = buildAutonomyRunRecord(params, rootDir, currentDir)

  const { created, recoveredStaleRuns } = await persistAutonomyRunRecord(
    record,
    rootDir,
    skipIfActiveSource,
  )
  for (const recovered of recoveredStaleRuns) {
    await syncFailedManagedFlowForRun(recovered, rootDir)
  }
  if (!created) {
    return null
  }
  await queueManagedFlowStepRunForRecord(record, rootDir)
  return record
}

export async function createAutonomyRun(
  params: CreateAutonomyRunParams,