option task = {
  name: "factory_temperature_rollup",
  every: 1m,
  offset: 0m,
}

from(bucket: "factory_metrics")
  |> range(start: -10m)
  |> filter(fn: (r) => r._measurement == "temperature")
  |> filter(fn: (r) => r._field == "value")
  |> aggregateWindow(every: 1m, fn: mean, createEmpty: false)
  |> set(key: "_measurement", value: "temperature_rollup")
  |> to(bucket: "factory_rollups", org: "plant-ops")