diff --git a/fam-core/config/config.yaml b/fam-core/config/config.yaml index 7d6e7d4..141ca53 100644 --- a/fam-core/config/config.yaml +++ b/fam-core/config/config.yaml @@ -30,7 +30,7 @@ dispatcher: edge_url: "http://129.146.203.203:5000/api/edge/video/enqueue" max_retries: 3 upload_timeout: 300 # 仅视频上传时间(不含 AI 处理) - stale_timeout: 3600 # PROCESSING 超时回收(Edge 处理 + 队列等待) + stale_timeout: 600 # PROCESSING 超时回收(10分钟,Edge 处理 + 队列等待) poller: poll_interval: 30 diff --git a/fam-core/src/fam_core/dispatcher/dispatcher.py b/fam-core/src/fam_core/dispatcher/dispatcher.py index a1d90f1..dae8a2d 100644 --- a/fam-core/src/fam_core/dispatcher/dispatcher.py +++ b/fam-core/src/fam_core/dispatcher/dispatcher.py @@ -97,7 +97,7 @@ class Dispatcher: self.edge_url, data=payload, files={'video': (os.path.basename(video_path), fh, 'video/mp4')}, - timeout=self.upload_timeout + timeout=(10, 60) ) except requests.RequestException as e: logger.error(f"[task_id={task_id}] 上传失败: {e}") diff --git a/fam-core/src/fam_core/poller/poller.py b/fam-core/src/fam_core/poller/poller.py index 818567a..62cf0ca 100644 --- a/fam-core/src/fam_core/poller/poller.py +++ b/fam-core/src/fam_core/poller/poller.py @@ -75,7 +75,7 @@ class Poller: resp = requests.get( self.results_url, params={'limit': self.batch_size}, - timeout=self.timeout + timeout=(10, 15) ) except requests.RequestException as e: logger.error(f"拉取结果失败: {e}")