diff --git a/app/services/job_clean_service.py b/app/services/job_clean_service.py index c947eaf..57575bb 100644 --- a/app/services/job_clean_service.py +++ b/app/services/job_clean_service.py @@ -32,7 +32,7 @@ async def run_job_clean() -> None: result = await pg.execute( text(""" SELECT * FROM app_job_data - WHERE clean_status = 'pending' + WHERE clean_status = 'pending' AND recruit_category in (0,1,2) LIMIT :limit FOR UPDATE SKIP LOCKED """),