zcdsj
/
paper_server
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 优化release_working_paper

This commit is contained in:
caoqianming 2026-02-10 10:08:46 +08:00
parent 33afe3af0b
commit 0fb8e5ff94
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/resm/tasks.py
View File

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