Function markAutonomyRunCompleted

src/utils/autonomyRuns.ts:712–739

(
  runId: string,
  rootDir?: string,
  nowMs?: number,
)

}

export async function markAutonomyRunCompleted(
  runId: string,
  rootDir?: string,
  nowMs?: number,
): Promise<AutonomyRunRecord | null> {
  const updated = await updateAutonomyRun(
    runId,
    current =>
      current.status === 'queued' || current.status === 'running'
        ? {
            ...current,
            status: 'completed',
            endedAt: nowMs ?? Date.now(),
            error: undefined,
          }
        : null,
    rootDir,
  )
  if (updated?.parentFlowId && updated.parentFlowSyncMode === 'managed') {
    await markManagedAutonomyFlowStepCompleted({
      flowId: updated.parentFlowId,
      runId: updated.runId,
      rootDir,
      nowMs: updated.endedAt,
    })
  }
  return updated
}

export async function markAutonomyRunFailed(
  runId: string,