diff --git a/apps/api/app/api/routes/lipsync.py b/apps/api/app/api/routes/lipsync.py index eb045be7a..dd4d4b125 100644 --- a/apps/api/app/api/routes/lipsync.py +++ b/apps/api/app/api/routes/lipsync.py @@ -195,7 +195,8 @@ def get_lipsync_job( if job.status not in ("completed", "failed"): # 三层防御 ①:如果距上次更新超过 30 秒,同步刷新一次(避免 background task # 静默失败导致前端永远看到 running);否则挂后台异步刷新(避免阻塞轮询)。 - from datetime import datetime as _dt, timezone as _tz + from datetime import datetime as _dt + from datetime import timezone as _tz _now = _dt.now(_tz.utc) _stale = job.updated_at is None or (_now - job.updated_at).total_seconds() > 30 diff --git a/apps/api/app/tasks/lipsync_tts.py b/apps/api/app/tasks/lipsync_tts.py index 109899582..3e106fd60 100644 --- a/apps/api/app/tasks/lipsync_tts.py +++ b/apps/api/app/tasks/lipsync_tts.py @@ -347,7 +347,8 @@ def poll_mediakit_status(self, job_id: str, user_id: str): logger.warning("[lipsync_poll] Job has no mediakit_task_id: job_id=%s status=%s", job_id, job.status) return - from app.services.lipsync_service import STATUS_COMPLETED as _SC, STATUS_FAILED as _SF + from app.services.lipsync_service import STATUS_COMPLETED as _SC + from app.services.lipsync_service import STATUS_FAILED as _SF from app.services.lipsync_service import LipsyncService from app.services.mediakit_client import MediaKitError, get_mediakit_client