Public/fastapi-cache
1
0
Fork 0
mirror of https://github.com/long2ice/fastapi-cache.git synced 2026-03-25 04:57:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: merge master

Browse Source
This commit is contained in:
vvanglro
2023-01-11 16:43:36 +08:00
parent 0d964fcf9f 0c73777930
commit ed101595f7
2 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGELOG.md
View File

@@ -9,6 +9,7 @@
- Add `py.typed` file and type hints - Add `py.typed` file and type hints
- Add TestCase - Add TestCase
- Fix cache decorate sync function - Fix cache decorate sync function
- Transparently handle backend connection failures.
### 0.2.0 ### 0.2.0

10
fastapi_cache/decorator.py
View File

@@ -123,13 +123,18 @@ def cache(
args=args, args=args,
kwargs=copy_kwargs, kwargs=copy_kwargs,
) )
try:
ttl, ret = await backend.get_with_ttl(cache_key) ttl, ret = await backend.get_with_ttl(cache_key)
except ConnectionError:
ttl, ret = 0, None
if not request: if not request:
if ret is not None: if ret is not None:
return coder.decode(ret) return coder.decode(ret)
ret = await ensure_async_func(*args, **kwargs) ret = await ensure_async_func(*args, **kwargs)
try:
await backend.set(cache_key, coder.encode(ret), expire or FastAPICache.get_expire()) await backend.set(cache_key, coder.encode(ret), expire or FastAPICache.get_expire())
except ConnectionError:
pass
return ret return ret
if request.method != "GET": if request.method != "GET":
@@ -148,7 +153,10 @@ def cache(
ret = await ensure_async_func(*args, **kwargs) ret = await ensure_async_func(*args, **kwargs)
try:
await backend.set(cache_key, coder.encode(ret), expire or FastAPICache.get_expire()) await backend.set(cache_key, coder.encode(ret), expire or FastAPICache.get_expire())
except ConnectionError:
pass
return ret return ret
return inner return inner