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-01-30 13:56:20 +08:00
parent 22de14fdea
commit 8c0efbecc2
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/resm/tasks.py
View File

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