def METHOD_NAME(self):
    for field in self.fields:
        val = self.cleaned_data[field]
        product = SQLProduct.objects.get(product_id=field.split('_')[1])
        assert product.domain == self.domain, 'Product {} attempted to be updated in domain {}'.format(
            product.product_id, self.domain
        )
        set_default_consumption_for_product(
            self.domain,
            product.product_id,
            val,
        )