From 0fb8e5ff94df91be9f38f562152a9a51181f2243 Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Tue, 10 Feb 2026 10:08:46 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=98=E5=8C=96release=5Fworking=5Fp?=
 =?UTF-8?q?aper?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/resm/tasks.py | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/apps/resm/tasks.py b/apps/resm/tasks.py
index ea0455b..3db86b2 100644
--- a/apps/resm/tasks.py
+++ b/apps/resm/tasks.py
@@ -333,11 +333,13 @@ def send_download_fulltext_task(number_of_task=100):
 
 @shared_task(base=CustomTask)
 def release_working_paper(minutes=10):
-    now = datetime.now()
-    five_minutes_ago = datetime.now() - timedelta(minutes=minutes)
-    qs = Paper.objects.filter(fetch_status__isnull=False, update_time__lte= five_minutes_ago)
-    x = qs.update(fetch_status=None, update_time=now)
-    return f"release {x} papers"
+    qs = Paper.objects.filter(fetch_status="downloading")
+    count = 0
+    for paper in qs:
+        if paper.update_time < datetime.now() - timedelta(minutes=minutes):
+            paper.fetch_end()
+            count += 1
+    return f"release {count} papers"
 
 @shared_task(base=CustomTask)
 def download_pdf(paper_id):