From 56fe8bebbe9dde93db27c1e1b58d1c27872e89da Mon Sep 17 00:00:00 2001 From: Untone Date: Thu, 16 Jan 2025 05:45:53 +0300 Subject: [PATCH] invalidate-cache-fix --- cache/cache.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cache/cache.py b/cache/cache.py index 82a8d535..8986476b 100644 --- a/cache/cache.py +++ b/cache/cache.py @@ -345,12 +345,12 @@ async def invalidate_shouts_cache(cache_keys: List[str]): "topic_456" # публикации по теме ]) """ - from services.redis import redis_client + from services.redis import redis for key in cache_keys: cache_key = f"shouts:{key}" try: - await redis_client.delete(cache_key) + await redis.execute("DEL", cache_key) logger.debug(f"Invalidated cache key: {cache_key}") except Exception as e: logger.error(f"Error invalidating cache key {cache_key}: {e}")