Function markAutonomyRunRunning

src/utils/autonomyRuns.ts:682–710

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

}

export async function markAutonomyRunRunning(
  runId: string,
  rootDir?: string,
  nowMs?: number,
): Promise<AutonomyRunRecord | null> {
  const updated = await updateAutonomyRun(
    runId,
    current =>
      current.status === 'queued'
        ? {
            ...current,
            status: 'running',
            startedAt: nowMs ?? Date.now(),
            ownerProcessId: process.pid,
            ownerSessionId: getSessionId(),
          }
        : null,
    rootDir,
  )
  if (updated?.parentFlowId && updated.parentFlowSyncMode === 'managed') {
    await markManagedAutonomyFlowStepRunning({
      flowId: updated.parentFlowId,
      runId: updated.runId,
      rootDir,
      nowMs: updated.startedAt,
    })
  }
  return updated
}

export async function markAutonomyRunCompleted(
  runId: string,