From 8c0efbecc275b00cc62657f27a5e3c495b08d56f Mon Sep 17 00:00:00 2001 From: caoqianming Date: Fri, 30 Jan 2026 13:56:20 +0800 Subject: [PATCH] feat: release_working_paper --- apps/resm/tasks.py | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/apps/resm/tasks.py b/apps/resm/tasks.py index 742812a..d5f8841 100644 --- a/apps/resm/tasks.py +++ b/apps/resm/tasks.py @@ -9,7 +9,7 @@ from django.core.cache import cache import requests from lxml import etree from celery import current_app -from datetime import datetime +from datetime import datetime, timedelta import random # config.email = "caoqianming@foxmail.com" @@ -294,6 +294,13 @@ def send_download_fulltext_task(number_of_task=100): return f"sent {task_count} download_pdf tasks" +@shared_task(base=CustomTask) +def release_working_paper(): + now = datetime.now() + five_minutes_ago = datetime.now() - timedelta(minutes=5) + 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" @shared_task(base=CustomTask) def download_pdf(paper_id):