Function queueManagedAutonomyFlowStepRun

src/utils/autonomyFlows.ts:565–606

(params: {
  flowId: string
  stepId: string
  stepIndex: number
  runId: string
  rootDir?: string
  nowMs?: number
})

}

export async function queueManagedAutonomyFlowStepRun(params: {
  flowId: string
  stepId: string
  stepIndex: number
  runId: string
  rootDir?: string
  nowMs?: number
}): Promise<AutonomyFlowRecord | null> {
  const rootDir = resolve(params.rootDir ?? getProjectRoot())
  return updateAutonomyFlowById(
    params.flowId,
    current => {
      const state = cloneManagedState(current.stateJson)
      const step = state?.steps[params.stepIndex]
      if (!state || !step || step.stepId !== params.stepId) {
        return current
      }
      step.status = 'queued'
      step.runId = params.runId
      step.startedAt = undefined
      step.endedAt = undefined
      step.error = undefined
      state.currentStepIndex = params.stepIndex
      return {
        ...current,
        revision: current.revision + 1,
        status: 'queued',
        currentStep: step.name,
        latestRunId: params.runId,
        runCount: current.runCount + 1,
        updatedAt: params.nowMs ?? Date.now(),
        endedAt: undefined,
        blockedRunId: undefined,
        blockedSummary: undefined,
        waitJson: undefined,
        stateJson: state,
        lastError: undefined,
      }
    },
    rootDir,
  )
}

export async function markManagedAutonomyFlowStepRunning(params: {
  flowId: string