From 8cae70a21f5ac1314441b3f4dd63e61bbe995549 Mon Sep 17 00:00:00 2001 From: Jet Li Date: Sat, 1 Feb 2025 05:42:02 +0000 Subject: [PATCH] Comment out the cleanup_document_job --- apps/content/scheduler/scheduler_manager.py | 20 +++++++++++--------- 1 file changed, 11 insertions(+), 9 deletions(-) diff --git a/apps/content/scheduler/scheduler_manager.py b/apps/content/scheduler/scheduler_manager.py index 1d7aab4..4d99f6c 100755 --- a/apps/content/scheduler/scheduler_manager.py +++ b/apps/content/scheduler/scheduler_manager.py @@ -20,12 +20,14 @@ async def register_job(scheduler): await init_lock(ScheduleJobLocker.REFRESH_SHAREPOINT_CONTENT_JOB_LOCKER) scheduler.add_job(refresh_sharepoint_content_job, "interval", seconds=(3600 + 3)) # Register cleanup_document_job as a one-time job - await init_lock(ScheduleJobLocker.CLEANUP_DOCUMENT_JOB_LOCKER) - execution_time = datetime.now() + timedelta( - seconds=60 - ) # Schedule to run 60 seconds from now - scheduler.add_job( - cleanup_document_job, # Job function - trigger=DateTrigger(run_date=execution_time), # One-time trigger - id="cleanup_document_one_time", # Optional: Give the job an ID - ) + # This job is just one-time job for removing many unused documents + # Run already, now comment it out + # await init_lock(ScheduleJobLocker.CLEANUP_DOCUMENT_JOB_LOCKER) + # execution_time = datetime.now() + timedelta( + # seconds=60 + # ) # Schedule to run 60 seconds from now + # scheduler.add_job( + # cleanup_document_job, # Job function + # trigger=DateTrigger(run_date=execution_time), # One-time trigger + # id="cleanup_document_one_time", # Optional: Give the job an ID + # )