18 lines
736 B
Python
18 lines
736 B
Python
import logging
|
|
from scheduler.constants import ScheduleJobLocker
|
|
from scheduler.schedule_job_locker import acquire_lock, release_lock
|
|
from backend.document.document_manager import DocumentManager
|
|
|
|
|
|
async def backfill_photo_id_job():
|
|
if await acquire_lock(ScheduleJobLocker.BACKFILL_PHOTO_ID_JOB_LOCKER, 3600):
|
|
try:
|
|
logging.info("Starting job to backfill photo id job.")
|
|
document_manager = DocumentManager()
|
|
await document_manager.backfill_photo_id()
|
|
logging.info("Exiting job to backfill photo id job.")
|
|
finally:
|
|
await release_lock(ScheduleJobLocker.BACKFILL_PHOTO_ID_JOB_LOCKER)
|
|
else:
|
|
logging.info("The job has been locked by other process.")
|