diff --git a/app/api/endpoints/system.py b/app/api/endpoints/system.py index 66c815f5..7602a00d 100644 --- a/app/api/endpoints/system.py +++ b/app/api/endpoints/system.py @@ -219,8 +219,5 @@ def execute_command(jobid: str, """ if not jobid: return schemas.Response(success=False, message="命令不能为空!") - if jobid == "subscribe_search": - Scheduler().start(jobid, state='R') - else: - Scheduler().start(jobid) + Scheduler().start(jobid) return schemas.Response(success=True) diff --git a/app/scheduler.py b/app/scheduler.py index 9b062517..798d90d2 100644 --- a/app/scheduler.py +++ b/app/scheduler.py @@ -71,6 +71,10 @@ class Scheduler(metaclass=Singleton): "transfer": { "func": TransferChain().process, "running": False, + }, + "clear_cache": { + "func": SchedulerChain().clear_cache, + "running": False, } } @@ -202,6 +206,18 @@ class Scheduler(metaclass=Singleton): minutes=10 ) + # 缓存清理服务,每隔24小时 + self._scheduler.add_job( + self.start, + "interval", + id="clear_cache", + name="缓存清理", + hours=24, + kwargs={ + 'job_id': 'clear_cache' + } + ) + # 打印服务 logger.debug(self._scheduler.print_jobs())