修改配置

supply_infra/scheduler/constants.py

@@ -3,5 +3,5 @@
 SUPPLY_PIPELINE_JOB_ID = "run_supply_pipeline"
 SUPPLY_PIPELINE_JOB_NAME = "供给数据流水线"
 
-# find_agent：当日全部 S/A 需求（有拓展点位），默认 2 线程并发找视频
-PIPELINE_FIND_AGENT_WORKERS = 2
+# find_agent：当日全部 S/A 需求（有拓展点位），单线程串行找视频
+PIPELINE_FIND_AGENT_WORKERS = 1

supply_infra/scheduler/jobs/discover_videos_from_demands.py

@@ -1,5 +1,5 @@
 """
-从全部 S/A 级需求及其拓展点位触发 find_agent 视频发现；有效视频满 200 提前结束。
+从全部 S/A 级需求及其拓展点位触发 find_agent 视频发现；有效视频满 100 提前结束。
 
 任务层负责查库与组装上下文；Agent 负责搜索、画像与分池落库。
 """
@@ -27,8 +27,8 @@ from supply_infra.services.video_discovery_service import get_video_discovery_se
 
 logger = logging.getLogger(__name__)
 
-_DEFAULT_WORKERS = 2
-_DAILY_PASSED_VIDEO_LIMIT = 200
+_DEFAULT_WORKERS = 1
+_DAILY_PASSED_VIDEO_LIMIT = 100
 
 
 def _resolve_biz_dt(biz_dt: str | None) -> str:
@@ -141,7 +141,7 @@ def discover_videos_from_demands(
     执行前会预写 video_discovery_run，并按 biz_dt + demand_grade_id 跳过已执行记录。
     默认处理全部 S/A（S 优先于 A、再按 score 排序）；仅 CLI --top-limit 可人为截断。
     当日 primary 去重视频达到上限时提前结束，否则跑完待处理队列。
-    默认 2 线程并发执行 find_agent（每条 S/A 需求一个 worker）。
+    默认单线程串行执行 find_agent（每条 S/A 需求依次处理）。
     """
     started_at = datetime.now()
     batch_run_id = uuid.uuid4().hex

tests/supply_infra/scheduler/test_discover_videos_from_demands.py

@@ -838,7 +838,7 @@ def test_evaluate_find_agent_run_fails_without_candidates(
 @patch(
     "supply_infra.scheduler.jobs.discover_videos_from_demands.list_find_demand_contexts"
 )
-def test_stops_discovery_after_200_passed_videos(
+def test_stops_discovery_after_100_passed_videos(
     mock_list_contexts,
     mock_filter_contexts,
     mock_count_passed,
@@ -863,14 +863,14 @@ def test_stops_discovery_after_200_passed_videos(
         contexts,
         {"total_loaded": 2, "skipped_already_done": 0},
     )
-    mock_count_passed.side_effect = [199, 200]
+    mock_count_passed.side_effect = [99, 100]
     mock_process.return_value = {"success": True, "skipped": False}
 
     result = discover_videos_from_demands("20260727", workers=1)
 
     assert mock_process.call_count == 1
     assert result["processed"] == 1
-    assert result["passed_videos"] == 200
+    assert result["passed_videos"] == 100
     assert result["stopped_by_passed_video_limit"] is True