ci: trigger staging rebuild for ditto hotfix

apps/api/app/services/lipsync_service.py

@@ -845,6 +845,30 @@ class LipsyncService:
         if job.status in (STATUS_COMPLETED, "failed"):
             return job
 
+        # Ditto 异步路径：mediakit_task_id 以 "ditto:" 开头，由 Celery 任务异步更新
+        # 不做 MediaKit 轮询，只检查是否卡住太久（>10 分钟）则标失败
+        if job.mediakit_task_id and job.mediakit_task_id.startswith("ditto:"):
+            if job.status in ("processing", "submitted"):
+                _now = datetime.now(UTC)
+                _upd = job.updated_at
+                if _upd is not None and _upd.tzinfo is None:
+                    _upd = _upd.replace(tzinfo=UTC)
+                stale_minutes = 10
+                if _upd and (_now - _upd).total_seconds() > stale_minutes * 60:
+                    logger.warning(
+                        "Ditto 异步任务超时（>%d 分钟），标记失败: job_id=%s",
+                        stale_minutes,
+                        job_id,
+                    )
+                    job.status = "failed"
+                    job.error_message = f"Ditto 处理超时（>{stale_minutes} 分钟）"
+                    job.error_code = "DittoTimeout"
+                    job.completed_at = _now
+                    job.updated_at = _now
+                    self.db.commit()
+                    self._refund_lip_sync(job)
+            return job
+
         # GPU 异步路径：mediakit_task_id 以 "gpu:" 开头，由 Celery 任务异步更新
         # 不做 MediaKit 轮询，只检查是否卡住太久（>30 分钟）则标失败
         if job.mediakit_task_id and job.mediakit_task_id.startswith("gpu:"):

apps/api/app/tasks/lipsync_ditto.py

@@ -246,8 +246,8 @@ def lipsync_ditto_process_async(self, job_id: str, user_id: str) -> None:
             # video_url 不传则用默认模板
         )
 
-        # Ditto 返回的 MP4 自带音频，直接标记完成
-        job.output_video_url = result.video_url
+        # Ditto 返回的 MP4 自带音频，签名 OSS URL（7天有效）后标记完成
+        job.output_video_url = _sign_media_url(result.video_url)
         # 探测时长（用于计费）
         duration = _probe_video_duration(result.video_bytes)
         if duration <= 0: