Function queueManagedFlowStepRunForRecord

src/utils/autonomyRuns.ts:458–482

(
  record: AutonomyRunRecord,
  rootDir: string,
)

}

async function queueManagedFlowStepRunForRecord(
  record: AutonomyRunRecord,
  rootDir: string,
): Promise<void> {
  if (
    record.parentFlowId &&
    record.flowStepId &&
    record.parentFlowSyncMode === 'managed'
  ) {
    const stepIndex =
      (
        await getAutonomyFlowById(record.parentFlowId, rootDir)
      )?.stateJson?.steps.findIndex(
        step => step.stepId === record.flowStepId,
      ) ?? 0
    await queueManagedAutonomyFlowStepRun({
      flowId: record.parentFlowId,
      stepId: record.flowStepId,
      stepIndex: stepIndex >= 0 ? stepIndex : 0,
      runId: record.runId,
      rootDir,
      nowMs: record.createdAt,
    })
  }
}

async function createAutonomyRunCore(
  params: CreateAutonomyRunParams,