From faeb05537c3e57c877d3bfad5f019adf8efa4e73 Mon Sep 17 00:00:00 2001
From: hbyang <hbyang@o2o.kr>
Date: Fri, 6 Mar 2026 14:42:22 +0900
Subject: [PATCH] =?UTF-8?q?=EC=8B=9C=EA=B0=84=EA=B0=92=20=EC=88=98?=
 =?UTF-8?q?=EC=A0=95=20.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 config.py          | 7 ++++++-
 jobs/sns_upload.py | 5 ++---
 main.py            | 7 +++++--
 3 files changed, 13 insertions(+), 6 deletions(-)

diff --git a/config.py b/config.py
index c86788d..847cf5f 100644
--- a/config.py
+++ b/config.py
@@ -1,6 +1,11 @@
+import os
+from pathlib import Path
+from zoneinfo import ZoneInfo
+
 from pydantic import Field
 from pydantic_settings import BaseSettings, SettingsConfigDict
-from pathlib import Path
+
+TIMEZONE = ZoneInfo(os.getenv("TIMEZONE", "Asia/Seoul"))
 
 PROJECT_DIR = Path(__file__).resolve().parent
 
diff --git a/jobs/sns_upload.py b/jobs/sns_upload.py
index 03d91a4..b45f15f 100644
--- a/jobs/sns_upload.py
+++ b/jobs/sns_upload.py
@@ -8,12 +8,11 @@ scheduled_at이 현재 시간 이전이고 status가 pending인 업로드 작업
 import asyncio
 import logging
 from datetime import datetime
-from zoneinfo import ZoneInfo
 
 import httpx
 from sqlalchemy import text
 
-from config import settings
+from config import settings, TIMEZONE
 from db import SessionLocal
 from jobs.base import BaseJob
 
@@ -47,7 +46,7 @@ class SnsUploadJob(BaseJob):
 
     async def _fetch_pending_uploads(self) -> list[int]:
         # DB의 다른 datetime 컬럼과 동일하게 Seoul time naive로 비교
-        now = datetime.now(ZoneInfo("Asia/Seoul")).replace(tzinfo=None).strftime("%Y-%m-%d %H:%M:%S")
+        now = datetime.now(TIMEZONE).replace(tzinfo=None).strftime("%Y-%m-%d %H:%M:%S")
         query = text("""
             SELECT id FROM social_upload
             WHERE status = 'pending'
diff --git a/main.py b/main.py
index a30a12b..b8fb047 100644
--- a/main.py
+++ b/main.py
@@ -6,15 +6,18 @@ APScheduler를 사용하여 jobs/ 에 등록된 잡들을 주기적으로 실행
 
 import asyncio
 import logging
+import time
 
 from apscheduler.schedulers.asyncio import AsyncIOScheduler
 
-from config import settings
+from config import settings, TIMEZONE
 from jobs import JOBS
 
+# 로그 타임스탬프를 KST로 출력
+logging.Formatter.converter = lambda *args: __import__("datetime").datetime.now(TIMEZONE).timetuple()
 logging.basicConfig(
     level=logging.INFO,
-    format="[%(asctime)s] [%(levelname)s] %(name)s - %(message)s",
+    format="[%(asctime)s KST] [%(levelname)s] %(name)s - %(message)s",
     datefmt="%Y-%m-%d %H:%M:%S",
 )