Fix cache errors
This commit is contained in:
1
.gitignore
vendored
1
.gitignore
vendored
@@ -219,3 +219,4 @@ osu-master/*
|
|||||||
geoip/*
|
geoip/*
|
||||||
newrelic.ini
|
newrelic.ini
|
||||||
logs/
|
logs/
|
||||||
|
osu-server-spectator-master/*
|
||||||
@@ -19,6 +19,7 @@ from app.database.pp_best_score import PPBestScore
|
|||||||
from app.database.score import Score, ScoreResp
|
from app.database.score import Score, ScoreResp
|
||||||
from app.dependencies.database import Database, get_redis
|
from app.dependencies.database import Database, get_redis
|
||||||
from app.dependencies.user import get_current_user
|
from app.dependencies.user import get_current_user
|
||||||
|
from app.log import logger
|
||||||
from app.models.score import GameMode
|
from app.models.score import GameMode
|
||||||
from app.models.user import BeatmapsetType
|
from app.models.user import BeatmapsetType
|
||||||
from app.service.user_cache_service import get_user_cache_service
|
from app.service.user_cache_service import get_user_cache_service
|
||||||
@@ -272,9 +273,13 @@ async def get_user_beatmapsets(
|
|||||||
raise HTTPException(400, detail="Invalid beatmapset type")
|
raise HTTPException(400, detail="Invalid beatmapset type")
|
||||||
|
|
||||||
# 异步缓存结果
|
# 异步缓存结果
|
||||||
asyncio.create_task(
|
async def cache_beatmapsets():
|
||||||
cache_service.cache_user_beatmapsets(user_id, type.value, resp, limit, offset)
|
try:
|
||||||
)
|
await cache_service.cache_user_beatmapsets(user_id, type.value, resp, limit, offset)
|
||||||
|
except Exception as e:
|
||||||
|
logger.error(f"Error caching user beatmapsets for user {user_id}, type {type.value}: {e}")
|
||||||
|
|
||||||
|
asyncio.create_task(cache_beatmapsets())
|
||||||
|
|
||||||
return resp
|
return resp
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user