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):