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

feat: release_working_paper2

This commit is contained in:
caoqianming 2026-01-30 14:01:03 +08:00
parent 8c0efbecc2
commit 16388682b9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/resm/tasks.py
View File

@ -295,9 +295,9 @@ def send_download_fulltext_task(number_of_task=100):
return f"sent {task_count} download_pdf tasks" return f"sent {task_count} download_pdf tasks"
@shared_task(base=CustomTask) @shared_task(base=CustomTask)
def release_working_paper(): def release_working_paper(minutes=10):
now = datetime.now() now = datetime.now()
five_minutes_ago = datetime.now() - timedelta(minutes=5) five_minutes_ago = datetime.now() - timedelta(minutes=minutes)
qs = Paper.objects.filter(fetch_status__isnull=False, update_time__lte= five_minutes_ago) qs = Paper.objects.filter(fetch_status__isnull=False, update_time__lte= five_minutes_ago)
x = qs.update(fetch_status=None, update_time=now) x = qs.update(fetch_status=None, update_time=now)
return f"release {x} papers" return f"release {x} papers"