From b70773fcf8353f9c02e9fd90ee49168c077bcfb0 Mon Sep 17 00:00:00 2001 From: zzx Date: Sun, 28 Sep 2025 19:54:32 +0800 Subject: [PATCH] =?UTF-8?q?fix(run):=20=E6=A3=80=E6=9F=A5=E7=88=AC?= =?UTF-8?q?=E8=99=AB=E7=BB=93=E6=9E=9C=E9=95=BF=E5=BA=A6=E5=B9=B6=E6=9B=B4?= =?UTF-8?q?=E6=96=B0=E4=BB=BB=E5=8A=A1=E7=8A=B6=E6=80=81=E5=BD=93=E7=88=AC?= =?UTF-8?q?=E8=99=AB=E8=BF=94=E5=9B=9E=E7=9A=84=E7=AD=94=E6=A1=88=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E9=95=BF=E5=BA=A6=E5=B0=8F=E4=BA=8E=E7=AD=89=E4=BA=8E?= =?UTF-8?q?20=E6=97=B6=EF=BC=8C=E5=B0=86=E4=BB=BB=E5=8A=A1=E7=8A=B6?= =?UTF-8?q?=E6=80=81=E6=9B=B4=E6=96=B0=E4=B8=BA4=EF=BC=88=E5=A4=B1?= =?UTF-8?q?=E8=B4=A5=EF=BC=89=EF=BC=8C=E5=B9=B6=E8=AE=B0=E5=BD=95=E9=94=99?= =?UTF-8?q?=E8=AF=AF=E6=97=A5=E5=BF=97=E5=92=8C=E5=9B=9E=E6=BB=9A=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=EF=BC=8C=E9=98=B2=E6=AD=A2=E6=97=A0=E6=95=88=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=8F=90=E4=BA=A4=E5=88=B0=E5=90=8E=E7=BB=AD=E6=B5=81?= =?UTF-8?q?=E7=A8=8B=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- run.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/run.py b/run.py index 2ef21f5..ff2e934 100644 --- a/run.py +++ b/run.py @@ -160,6 +160,14 @@ async def ai_seo_job(browser, platform_ids, time_range, job_id, type_name, run_i # data.update(rest.get("data")) # search_results.append(data) # answer_data['search_result'] = search_results + + if len(answer_data.get('answer', '') <= 20): + await AiSeoApis.update_task_status(task_id, 4) + logger.error(f"爬虫结果长度过短: id: {task_data['id']} platform_id: {task_data['platform_id']}") + logger.error(f"回滚任务状态: id: {task_id}") + logger.info(f"{answer_data.get('answer', '')}") + return + result = await AiSeoApis.submit_task(answer_data) logger.info(f"任务提交成功: id: {task_data['id']}") spider_pool.pop(run_id, None)