diff --git a/app/services/job_clean_service.py b/app/services/job_clean_service.py index 5a0e4d9..ce3f2c4 100644 --- a/app/services/job_clean_service.py +++ b/app/services/job_clean_service.py @@ -97,7 +97,7 @@ async def _fetch_one() -> dict | None: SET clean_status = 'cleaning', clean_started_at = NOW() WHERE id = ( SELECT id FROM app_job_data - WHERE clean_status = 'pending' AND recruit_category IN (0,1,2) + WHERE clean_status = 'pending' AND verify_status = 'success' AND recruit_category IN (0,1,2) LIMIT 1 FOR UPDATE SKIP LOCKED )