@@ -26,6 +26,10 @@ def wrapper(*args, **kwargs):
26
26
try :
27
27
value = cache .get (cache_key )
28
28
except Exception :
29
+ logger .warning (
30
+ f'Error retrieving value from Cache for Key: { function_cache_key } ' ,
31
+ exc_info = True ,
32
+ )
29
33
value = None
30
34
31
35
if value is None :
@@ -38,7 +42,7 @@ def wrapper(*args, **kwargs):
38
42
39
43
except CacheSetError :
40
44
logger .warning (
41
- f'Error saving value to Cache for Key: { cache_key } ' ,
45
+ f'Error saving value to Cache for Key: { function_cache_key } ' ,
42
46
exc_info = True ,
43
47
)
44
48
@@ -77,6 +81,10 @@ def wrapper(*args, **kwargs):
77
81
try :
78
82
value = cache .get (cache_key )
79
83
except Exception :
84
+ logger .warning (
85
+ f'Error retrieving value from Cache for Key: { function_cache_key } ' ,
86
+ exc_info = True ,
87
+ )
80
88
value = None
81
89
82
90
if value is None :
@@ -88,7 +96,7 @@ def wrapper(*args, **kwargs):
88
96
cache .set (cache_key , value , timeout )
89
97
except CacheSetError :
90
98
logger .warning (
91
- f'Error saving value to Cache for Key: { cache_key } ' ,
99
+ f'Error saving value to Cache for Key: { function_cache_key } ' ,
92
100
exc_info = True ,
93
101
)
94
102
@@ -141,10 +149,14 @@ def __get__(self, obj, objtype):
141
149
return fn
142
150
143
151
def __call__ (self , * args , ** kwargs ):
144
- cache_key = self .create_cache_key (* args , ** kwargs )
152
+ cache_key , function_cache_key = self .create_cache_key (* args , ** kwargs )
145
153
try :
146
154
value = cache .get (cache_key )
147
155
except Exception :
156
+ logger .warning (
157
+ f'Error retrieving value from Cache for Key: { function_cache_key } ' ,
158
+ exc_info = True ,
159
+ )
148
160
value = None
149
161
if value is None :
150
162
value = self .func (* args , ** kwargs )
@@ -155,7 +167,7 @@ def __call__(self, *args, **kwargs):
155
167
cache .set (cache_key , value , timeout )
156
168
except CacheSetError :
157
169
logger .warning (
158
- f'Error saving value to Cache for Key: { cache_key } ' ,
170
+ f'Error saving value to Cache for Key: { function_cache_key } ' ,
159
171
exc_info = True ,
160
172
)
161
173
return value
@@ -168,14 +180,14 @@ def _invalidate(self, *args, **kwargs):
168
180
:param kwargs: The kwargs passed into the original function.
169
181
:rtype: None
170
182
"""
171
- cache_key = self .create_cache_key (* args , ** kwargs )
183
+ cache_key , _ = self .create_cache_key (* args , ** kwargs )
172
184
cache .delete (cache_key )
173
185
174
186
def create_cache_key (self , * args , ** kwargs ):
175
187
# Need to include the first arg (self) in the cache key
176
188
func_name = utils .get_function_name (self .func )
177
189
function_cache_key = utils .get_function_cache_key (func_name , args , kwargs )
178
190
cache_key = utils .get_hashed_cache_key (function_cache_key )
179
- return cache_key
191
+ return cache_key , function_cache_key
180
192
181
193
return wrapper
0 commit comments