Skip to content

[Refactor]: 데일리 스케줄러 재시도 실패 시 critical 로그 저장 #34

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
likerhythm merged 2 commits into from
Aug 25, 2025
Merged

[Refactor]: 데일리 스케줄러 재시도 실패 시 critical 로그 저장 #34

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
dc3a710
refactor[#33]: 데일리 스케줄러 재시도 실패 시 critical log를 저장하도록 수정
likerhythm Aug 24, 2025
0fdc928
chore[#33]: 테스트용으로 던진 예외 제거
likerhythm Aug 24, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions app/services/daily_weight_resizer.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ async def resize_weight(
if attempt < MAX_RETRIES:
await asyncio.sleep(RETRY_DELAY_SEC)
else:
await gen_error_log("모든 재시도 실패, 로그 조회 불가", e)
await gen_critical_log("모든 재시도 실패, 로그 조회 불가", e)
print("💥 가중치 조회 실패")
return

Expand Down Expand Up @@ -113,7 +113,7 @@ async def resize_weight(
if attempt < MAX_RETRIES:
await gen_warning_log(f"[{attempt}/{MAX_RETRIES}] Redis 저장 재시도", e)
else:
await gen_error_log(f"사용자 {user_id} 벡터 Redis 저장 실패", e)
await gen_critical_log(f"사용자 {user_id} 벡터 Redis 저장 실패", e)

# 실패 로그 재시도
error_logs_cnt = 0
Expand All @@ -128,7 +128,7 @@ async def resize_weight(
await gen_warning_log(f"[{attempt}/{MAX_RETRIES}] 보상 트랜잭션 재시도", e)
else:
error_logs_cnt += 1
await gen_error_log(f"보상 트랜잭션 실패, log_id: {log['_id']}", e)
await gen_critical_log(f"보상 트랜잭션 실패, log_id: {log['_id']}", e)
if error_logs_cnt == 0:
print("✅ 보상 트랜잭션 재시도 성공")
else:
Expand Down Expand Up @@ -156,11 +156,11 @@ async def remove_managed_action_log():
if attempt < MAX_RETRIES:
await asyncio.sleep(RETRY_DELAY_SEC)
else:
await gen_error_log("모든 재시도 실패, managed_action_log 삭제 불가", e)
await gen_critical_log("모든 재시도 실패, managed_action_log 삭제 불가", e)
return

async def gen_error_log(message: str, e: Exception):
return logger.error(f"{LOG_PREFIX} {message} , error : {e}")
async def gen_critical_log(message: str, e: Exception):
return logger.critical(f"{LOG_PREFIX} {message} , error : {e}")

async def gen_warning_log(message: str, e: Exception):
return logger.warning(f"{LOG_PREFIX} {message} , error : {e}")