diff --git a/apps/worker/worker_app/tasks/viral_video.py b/apps/worker/worker_app/tasks/viral_video.py index c030b137c..47dae07e7 100644 --- a/apps/worker/worker_app/tasks/viral_video.py +++ b/apps/worker/worker_app/tasks/viral_video.py @@ -380,8 +380,7 @@ def _normalize_image_url(raw: str, idx: int) -> str: # 用 HEAD 请求会返回 403 SignatureDoesNotMatch 误判 URL 无效,实际 GET 下载完全正常。 # Range: bytes=0-1024 只取前1KB,开销极小。 try: - _r = _req.get(url, timeout=5, allow_redirects=True, stream=True, - headers={"Range": "bytes=0-1024"}) + _r = _req.get(url, timeout=5, allow_redirects=True, stream=True, headers={"Range": "bytes=0-1024"}) if _r.status_code >= 400: logger.warning("[爆款视频] 图片 #%d URL 可达性检查返回 %d: %s", idx, _r.status_code, url[:120]) _r.close() @@ -431,8 +430,10 @@ def _analyze_single_image( # 避免底层 max_retries=1 导致 lite timeout × 2 + pro timeout × 2 最坏 240s+ _t0 = time.time() try: - from packages.shared.ai_client import get_doubao_client as _gdc import json as _json + + from packages.shared.ai_client import get_doubao_client as _gdc + _client = _gdc() _messages = [ {"role": "system", "content": system},