chore(linter): make lint happy
This commit is contained in:
@@ -12,7 +12,7 @@ from app.models.beatmap import SearchQueryModel
|
|||||||
from app.models.model import Cursor
|
from app.models.model import Cursor
|
||||||
from app.utils import bg_tasks
|
from app.utils import bg_tasks
|
||||||
|
|
||||||
from ._base import BaseFetcher
|
from ._base import BaseFetcher, TokenAuthError
|
||||||
|
|
||||||
from httpx import AsyncClient
|
from httpx import AsyncClient
|
||||||
import redis.asyncio as redis
|
import redis.asyncio as redis
|
||||||
@@ -343,7 +343,8 @@ class BeatmapsetFetcher(BaseFetcher):
|
|||||||
await self.prefetch_next_pages(query, api_response["cursor"], redis_client, pages=2)
|
await self.prefetch_next_pages(query, api_response["cursor"], redis_client, pages=2)
|
||||||
except RateLimitError:
|
except RateLimitError:
|
||||||
logger.opt(colors=True).info(
|
logger.opt(colors=True).info(
|
||||||
f"<yellow>[BeatmapsetFetcher]</yellow> Warmup prefetch skipped for {query.sort} due to rate limit"
|
f"<yellow>[BeatmapsetFetcher]</yellow> Warmup prefetch "
|
||||||
|
f"skipped for {query.sort} due to rate limit"
|
||||||
)
|
)
|
||||||
|
|
||||||
except RateLimitError:
|
except RateLimitError:
|
||||||
|
|||||||
@@ -364,8 +364,6 @@ async def oauth_token(
|
|||||||
refresh_token_str,
|
refresh_token_str,
|
||||||
settings.access_token_expire_minutes * 60,
|
settings.access_token_expire_minutes * 60,
|
||||||
)
|
)
|
||||||
# 打印jwt
|
|
||||||
logger.info(f"[Auth] Generated JWT for user {user_id}: {access_token}")
|
|
||||||
return TokenResponse(
|
return TokenResponse(
|
||||||
access_token=access_token,
|
access_token=access_token,
|
||||||
token_type="Bearer",
|
token_type="Bearer",
|
||||||
@@ -417,8 +415,6 @@ async def oauth_token(
|
|||||||
new_refresh_token,
|
new_refresh_token,
|
||||||
settings.access_token_expire_minutes * 60,
|
settings.access_token_expire_minutes * 60,
|
||||||
)
|
)
|
||||||
# 打印jwt
|
|
||||||
logger.info(f"[Auth] Generated JWT for user {token_record.user_id}: {access_token}")
|
|
||||||
return TokenResponse(
|
return TokenResponse(
|
||||||
access_token=access_token,
|
access_token=access_token,
|
||||||
token_type="Bearer",
|
token_type="Bearer",
|
||||||
@@ -530,9 +526,6 @@ async def oauth_token(
|
|||||||
settings.access_token_expire_minutes * 60,
|
settings.access_token_expire_minutes * 60,
|
||||||
)
|
)
|
||||||
|
|
||||||
# 打印生成的令牌
|
|
||||||
logger.info(f"[Auth] Generated access token for client {client_id}: {access_token}")
|
|
||||||
|
|
||||||
return TokenResponse(
|
return TokenResponse(
|
||||||
access_token=access_token,
|
access_token=access_token,
|
||||||
token_type="Bearer",
|
token_type="Bearer",
|
||||||
|
|||||||
Reference in New Issue
Block a user