INNER CODE UNIT · Python

_run_cleanup_job

giuseppe99barchetta/SuggestArr · api_service/app.py:321

    def _run_cleanup_job():
        if not _cleanup_run_lock.acquire(blocking=False):
            logger.info("Cleanup cron skipped: a run is already in progress.")
            return
        try:
            _asyncio.run(execute_cleanup_job())
        except Exception as exc:
            logger.error(f"Cleanup job error: {exc}")
        finally:
            try:
                _cleanup_run_lock.release()
            except RuntimeError:
                pass
    job_manager.scheduler.add_job(
        _run_cleanup_job,
        'cron',
        hour=4, minute=15,
        id='cleanup_automation',

View source record →