From 50277171d73654b597c55fc2f7cb71ab4a9b3513 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Thu, 29 Jan 2026 14:33:22 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BF=AE=E6=94=B9=E9=BB=98=E8=AE=A4?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/resm/tasks.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/resm/tasks.py b/apps/resm/tasks.py index 79e4615..172b76d 100644 --- a/apps/resm/tasks.py +++ b/apps/resm/tasks.py @@ -117,7 +117,7 @@ def show_task_run(def_name: str): return cache.get(def_name, True) @shared_task(base=CustomTask) -def get_abstract_from_elsevier(publication_year: int = None, number_of_task:int = 100): +def get_abstract_from_elsevier(publication_year: int = None, number_of_task:int = 20): def_name = get_abstract_from_elsevier.name if not show_task_run(def_name): return "stoped" @@ -263,7 +263,7 @@ def can_send_more(): return cache.get(RUNNING_KEY, 0) < MAX_RUNNING @shared_task(base=CustomTask) -def send_download_fulltext_task(number_of_task=100): +def send_download_fulltext_task(number_of_task=MAX_RUNNING): qs = Paper.objects.filter(is_oa=True, has_fulltext=False, fail_reason=None) if not qs.exists(): return "done" @@ -369,7 +369,7 @@ def save_pdf_from_oa_url(paper:Paper): def save_pdf_from_openalex(paper:Paper): if cache.get("openalex_api_exceed"): - return "Insufficient credits" + return "find cache Insufficient credits" # 尝试openalex下载 try: res = requests.get(url=f"https://content.openalex.org/works/{paper.openalex_id}.pdf",