Function getProgressMarkers

apps/sim/lib/logs/execution/progress-markers.ts:210–232

(
  executionId: string
)

 * never wipes the only copy of markers that are still in Redis.
 */
export async function getProgressMarkers(
  executionId: string
): Promise<ExecutionProgressMarkers | null> {
  const redis = getMarkerClient()
  if (!redis) return {}

  try {
    const fields = await redis.hgetall(markerKey(executionId))
    if (!fields || Object.keys(fields).length === 0) return {}

    const result: ExecutionProgressMarkers = {}
    const started = parseStartedMarker(fields[STARTED_FIELD])
    if (started) result.lastStartedBlock = started
    const completed = parseCompletedMarker(fields[COMPLETED_FIELD])
    if (completed) result.lastCompletedBlock = completed
    return result
  } catch (error) {
    logger.error(`Failed to read progress markers for execution ${executionId}`, {
      error: toError(error).message,
    })
    return null
  }
}

/**
 * Delete the markers for an execution. Called at every terminal/pause boundary