diff --git a/apps/resm/tasks.py b/apps/resm/tasks.py index d5f8841..1a2a045 100644 --- a/apps/resm/tasks.py +++ b/apps/resm/tasks.py @@ -295,9 +295,9 @@ 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(): +def release_working_paper(minutes=10): 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) x = qs.update(fetch_status=None, update_time=now) return f"release {x} papers"