Function setMarker

apps/sim/lib/logs/execution/progress-markers.ts:67–96

* Write a marker field under the monotonic guard, refreshing the key TTL. The * TTL is a backstop for executions that die without a terminal/pause boundary * (deterministic cleanup is clearProgressMarkers); it mirrors the * admission-reservation TTL so a crashed run's marker key and slot

(
  executionId: string,
  field: string,
  timestampField: 'startedAt' | 'endedAt',
  timestamp: string,
  marker: ExecutionLastStartedBlock | ExecutionLastCompletedBlock
)

 * so callers can fall back to the SQL path on a missing client or a failure.
 */
async function setMarker(
  executionId: string,
  field: string,
  timestampField: 'startedAt' | 'endedAt',
  timestamp: string,
  marker: ExecutionLastStartedBlock | ExecutionLastCompletedBlock
): Promise<boolean> {
  const redis = getMarkerClient()
  if (!redis) return false

  try {
    await redis.eval(
      SET_MARKER_SCRIPT,
      1,
      markerKey(executionId),
      field,
      timestampField,
      timestamp,
      JSON.stringify(marker),
      getExecutionReservationTtlMs().toString()
    )
    return true
  } catch (error) {
    logger.error(`Failed to persist progress marker for execution ${executionId}`, {
      field,
      error: toError(error).message,
    })
    return false
  }
}

/**
 * Persist the last-started-block marker. Returns `false` (caller should fall