diff --git a/internal/ozon/products/repository_api.go b/internal/ozon/products/repository_api.go index dd145f5..936c8af 100644 --- a/internal/ozon/products/repository_api.go +++ b/internal/ozon/products/repository_api.go @@ -23,7 +23,7 @@ type apiRepository struct { } func GetProductsKey(identifier string) string { - return fmt.Sprintf("ozon:products:%s", identifier) + return fmt.Sprintf("ozon:products:%s:compressed", identifier) } func NewAPIRepository(marketplaceRepository marketplace.Repository) Repository { diff --git a/internal/wb/products/repository_api.go b/internal/wb/products/repository_api.go index 9e87a90..37b137a 100644 --- a/internal/wb/products/repository_api.go +++ b/internal/wb/products/repository_api.go @@ -26,7 +26,7 @@ type apiRepository struct { } func GetProductsKey(identifier string) string { - return fmt.Sprintf("wb:products:%s", identifier) + return fmt.Sprintf("wb:products:%s:compressed", identifier) } func (a apiRepository) ParseMarketplace(ctx context.Context, marketplaceId int) (*marketplace.Marketplace, string, error) { diff --git a/internal/ym/products/repository_api.go b/internal/ym/products/repository_api.go index 057c323..bbb1f95 100644 --- a/internal/ym/products/repository_api.go +++ b/internal/ym/products/repository_api.go @@ -40,7 +40,7 @@ func NewAPIRepository(marketplaceRepository marketplace.Repository) Repository { } func GetProductKey(identifier string) string { - return fmt.Sprintf("ym:products:%s", identifier) + return fmt.Sprintf("ym:products:%s:compressed", identifier) } // getBusinessID retrieves the business ID for a given marketplace by looking up the campaign