Различные методы доступа к Pyro Paramstore дают разные результаты

Я следую вводному руководству Pyro по прогнозированию и пытаюсь получить доступ к изученным параметрам после обучения модели, я получаю разные результаты, используя разные методы доступа для некоторых из них (при получении идентичных результатов для других).

Вот урезанный воспроизводимый код из учебника:

import torch
import pyro
import pyro.distributions as dist
from pyro.contrib.examples.bart import load_bart_od
from pyro.contrib.forecast import ForecastingModel, Forecaster

pyro.enable_validation(True)
pyro.clear_param_store()

pyro.__version__
# '1.3.1'
torch.__version__
# '1.5.0+cu101'

# import & prepare the data
dataset = load_bart_od()
T, O, D = dataset["counts"].shape
data = dataset["counts"][:T // (24 * 7) * 24 * 7].reshape(T // (24 * 7), -1).sum(-1).log()
data = data.unsqueeze(-1)
T0 = 0              # begining
T2 = data.size(-2)  # end
T1 = T2 - 52        # train/test split

# define the model class
class Model1(ForecastingModel):

    def model(self, zero_data, covariates):
        data_dim = zero_data.size(-1)  
        feature_dim = covariates.size(-1)

        bias = pyro.sample("bias", dist.Normal(0, 10).expand([data_dim]).to_event(1))
        weight = pyro.sample("weight", dist.Normal(0, 0.1).expand([feature_dim]).to_event(1))
        prediction = bias + (weight * covariates).sum(-1, keepdim=True)
        assert prediction.shape[-2:] == zero_data.shape

        noise_scale = pyro.sample("noise_scale", dist.LogNormal(-5, 5).expand([1]).to_event(1))
        noise_dist = dist.Normal(0, noise_scale)

        self.predict(noise_dist, prediction)

# fit the model
pyro.set_rng_seed(1)
pyro.clear_param_store()
time = torch.arange(float(T2)) / 365
covariates = torch.stack([time], dim=-1)
forecaster = Forecaster(Model1(), data[:T1], covariates[:T1], learning_rate=0.1)

Все идет нормально; теперь я хочу проверить изученные скрытые параметры, хранящиеся вParamstore. Кажется, есть несколько способов сделать это; используяget_all_param_names() метод:

for name in pyro.get_param_store().get_all_param_names():
    print(name, pyro.param(name).data.numpy())

я получил

AutoNormal.locs.bias [14.585433]
AutoNormal.scales.bias [0.00631594]
AutoNormal.locs.weight [0.11947815]
AutoNormal.scales.weight [0.00922901]
AutoNormal.locs.noise_scale [-2.0719821]
AutoNormal.scales.noise_scale [0.03469057]

Но используя named_parameters() метод:

pyro.get_param_store().named_parameters()

дает те же значения для местоположения (locs) параметров, но разные значения для всехscales те:

dict_items([
('AutoNormal.locs.bias', Parameter containing: tensor([14.5854], requires_grad=True)), 
('AutoNormal.scales.bias', Parameter containing: tensor([-5.0647], requires_grad=True)), 
('AutoNormal.locs.weight', Parameter containing: tensor([0.1195], requires_grad=True)), 
('AutoNormal.scales.weight', Parameter containing: tensor([-4.6854], requires_grad=True)),
('AutoNormal.locs.noise_scale', Parameter containing: tensor([-2.0720], requires_grad=True)), 
('AutoNormal.scales.noise_scale', Parameter containing: tensor([-3.3613], requires_grad=True))
])

Как это возможно? Согласно документации,Paramstoreэто простое хранилище ключей и значений; а в нем всего шесть ключей:

pyro.get_param_store().get_all_param_names() # .keys() method gives identical result
# result
dict_keys([
'AutoNormal.locs.bias',
'AutoNormal.scales.bias', 
'AutoNormal.locs.weight', 
'AutoNormal.scales.weight', 
'AutoNormal.locs.noise_scale', 
'AutoNormal.scales.noise_scale'])

таким образом, один метод не может получить доступ к одному набору элементов, а другой - к другому.

Я что-то упустил?

2 ответа

Решение

Вот ситуация, описанная в ветке Github, которую я открыл параллельно с этим вопросом...

Paramstoreне более просто простой магазин ключ-значение - оно также выполняет преобразования ограничений; цитируя разработчика Pyro из приведенной выше ссылки:

вот немного исторической справки. ВParamStoreизначально был просто хранилищем ключей и значений. Затем мы добавили поддержку ограниченных параметров; это ввело новый уровень разделения между ограниченными значениями, обращенными к пользователю, и внутренними неограниченными значениями. Мы создали новый dict-подобный пользовательский интерфейс, который предоставлял только ограниченные значения, но для сохранения обратной совместимости со старым кодом мы сохранили старый интерфейс. Эти два интерфейса различаются в исходных файлах [...], но, как вы заметили, похоже, что мы забыли пометить старый интерфейс как УСТАРЕВШИЙ.

Думаю, при разъяснении документов нам следует:

  1. поясните, что ParamStore больше не является простым хранилищем ключей и значений, но также выполняет преобразования ограничений;

  2. пометить все методы интерфейса "старого" стиля как УСТАРЕВШИЕ;

  3. убрать использование интерфейса в "старом" стиле из примеров и руководств.

Как следствие, оказывается, что пока pyro.param() возвращает результаты в ограниченном (ориентированном на пользователя) пространстве, более старый метод named_parameters() возвращает неограниченные (т.е. только для внутреннего использования) значения, отсюда очевидное несоответствие.

Действительно, нетрудно убедиться, что scales значения, возвращаемые двумя вышеуказанными методами, связаны логарифмическим преобразованием:

import numpy as np
items = list(pyro.get_param_store().named_parameters())  # unconstrained space

i = 0
for name in pyro.get_param_store().keys():  
  if 'scales' in name:
    temp = np.log(
                  pyro.param(name).item()  # constrained space
                 )
    print(temp, items[i][1][0].item() , np.allclose(temp, items[i][1][0].item()))
  i+=1

# result:
-5.027793402915326 -5.0277934074401855 True
-4.600319371162187 -4.6003193855285645 True
-3.3920585732532835 -3.3920586109161377 True

Почему это несоответствие влияет только на scalesпараметры? Это потому чтоscales(т.е. по существу отклонения) по определению должны быть положительными; это не относится кlocs (т.е. средства), которые не ограничены, поэтому два представления для них совпадают.

В результате вышеуказанного вопроса в список добавлен новый маркер.Paramstore документация с соответствующей подсказкой:

Обычно параметры связаны как с ограниченными, так и с неограниченными значениями. например, под капотом параметр, который должен быть положительным, представлен как неограниченный тензор в пространстве журнала.

а также в документации изnamed_parameters() метод старого интерфейса:

Обратите внимание, что в случае, если параметр ограничен, Unlimited_value находится в неограниченном пространстве, неявно используемом ограничением.

pyro.param() возвращает преобразованные параметры в этом случае в положительные числа дляscales.

Другие вопросы по тегам