Added another check in case cached object failed
This commit is contained in:
parent
3b66f780a9
commit
fa8231eb71
|
@ -135,7 +135,8 @@ async def get_content(key: str):
|
||||||
# We want to check here if the key exists in cache, and it was not created more than an hour ago
|
# We want to check here if the key exists in cache, and it was not created more than an hour ago
|
||||||
# We also want to make sure that if what we're getting in cache has content
|
# We also want to make sure that if what we're getting in cache has content
|
||||||
# if not, lets make sure something didn't go awry, by getting from the database instead
|
# if not, lets make sure something didn't go awry, by getting from the database instead
|
||||||
if cached is None or len(cached.values) == 0 or (pendulum.utcnow() - cached.refreshed).hours >= 1:
|
if cached is None or isinstance(cached, {}) or len(cached.values) == 0 or (
|
||||||
|
pendulum.utcnow() - cached.refreshed).hours >= 1:
|
||||||
value = await _get_content(key)
|
value = await _get_content(key)
|
||||||
# If we found this object not cached, cache it
|
# If we found this object not cached, cache it
|
||||||
cache[key] = value
|
cache[key] = value
|
||||||
|
@ -143,6 +144,7 @@ async def get_content(key: str):
|
||||||
value = cached.values
|
value = cached.values
|
||||||
return value
|
return value
|
||||||
|
|
||||||
|
|
||||||
# This is our internal method to get content from the database
|
# This is our internal method to get content from the database
|
||||||
async def _get_content(key: str):
|
async def _get_content(key: str):
|
||||||
# We need to make sure we're using asyncio
|
# We need to make sure we're using asyncio
|
||||||
|
|
Loading…
Reference in a new issue