Function updateAutonomyFlowById

src/utils/autonomyFlows.ts:440–456

(
  flowId: string,
  updater: (current: AutonomyFlowRecord) => AutonomyFlowRecord,
  rootDir: string = getProjectRoot(),
)

}

async function updateAutonomyFlowById(
  flowId: string,
  updater: (current: AutonomyFlowRecord) => AutonomyFlowRecord,
  rootDir: string = getProjectRoot(),
): Promise<AutonomyFlowRecord | null> {
  return withAutonomyPersistenceLock(rootDir, async () => {
    const flows = await listAutonomyFlows(rootDir)
    const index = flows.findIndex(flow => flow.flowId === flowId)
    if (index === -1) {
      return null
    }
    const next = normalizeFlowRecord(updater(cloneFlowRecord(flows[index]!)))
    flows[index] = next
    await writeAutonomyFlows(flows, rootDir)
    return next
  })
}

export function createManagedAutonomyFlowKey(params: {
  trigger: AutonomyTriggerKind