From 97379bebd470d0336f0e74c7eb2e1a0842dc0c49 Mon Sep 17 00:00:00 2001 From: Dohyun Lim Date: Fri, 6 Mar 2026 15:29:55 +0900 Subject: [PATCH] add logs --- jobs/sns_upload.py | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) diff --git a/jobs/sns_upload.py b/jobs/sns_upload.py index b45f15f..d8aa6a0 100644 --- a/jobs/sns_upload.py +++ b/jobs/sns_upload.py @@ -7,7 +7,7 @@ scheduled_at이 현재 시간 이전이고 status가 pending인 업로드 작업 import asyncio import logging -from datetime import datetime +from datetime import datetime, timezone import httpx from sqlalchemy import text @@ -46,7 +46,20 @@ class SnsUploadJob(BaseJob): async def _fetch_pending_uploads(self) -> list[int]: # DB의 다른 datetime 컬럼과 동일하게 Seoul time naive로 비교 - now = datetime.now(TIMEZONE).replace(tzinfo=None).strftime("%Y-%m-%d %H:%M:%S") + utc_now = datetime.now(tz=timezone.utc) + server_now = datetime.now() + seoul_aware = datetime.now(TIMEZONE) + now = seoul_aware.replace(tzinfo=None).strftime("%Y-%m-%d %H:%M:%S") + + logger.debug( + f"[SNS_UPLOAD][TIME_DEBUG] " + f"서버 UTC: {utc_now.strftime('%Y-%m-%d %H:%M:%S')}, " + f"서버 로컬: {server_now.strftime('%Y-%m-%d %H:%M:%S')}, " + f"Seoul aware: {seoul_aware.isoformat()}, " + f"TIMEZONE={TIMEZONE} (key={TIMEZONE.key}), " + f"now(쿼리용): {now}" + ) + query = text(""" SELECT id FROM social_upload WHERE status = 'pending'