codfrm/MoviePilot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix TorrentRemover #92

Browse Source
This commit is contained in:
jxxghp
2023-08-12 18:18:49 +08:00
parent a90695d1fa
commit 61af9edd95
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
app/plugins/torrentremover/__init__.py
View File

@ -95,15 +95,16 @@ class TorrentRemover(_PluginBase):
self.tr = Transmission() self.tr = Transmission()
if self._cron: if self._cron:
try: try:
self._scheduler.add_job(self.delete_torrents, self._scheduler.add_job(func=self.delete_torrents,
CronTrigger.from_crontab(self._cron)) trigger=CronTrigger.from_crontab(self._cron),
name="自动删种服务")
logger.info(f"自动删种服务启动，周期：{self._cron}") logger.info(f"自动删种服务启动，周期：{self._cron}")
except Exception as err: except Exception as err:
logger.error(f"自动删种服务启动失败：{str(err)}") logger.error(f"自动删种服务启动失败：{str(err)}")
self.systemmessage.put(f"自动删种服务启动失败：{str(err)}") self.systemmessage.put(f"自动删种服务启动失败：{str(err)}")
if self._onlyonce: if self._onlyonce:
logger.info(f"自动删种服务启动，立即运行一次") logger.info(f"自动删种服务启动，立即运行一次")
self._scheduler.add_job(self.delete_torrents, 'date', self._scheduler.add_job(func=self.delete_torrents, trigger='date',
run_date=datetime.now( run_date=datetime.now(
tz=pytz.timezone(settings.TZ)) + timedelta(seconds=3) tz=pytz.timezone(settings.TZ)) + timedelta(seconds=3)
) )
@ -130,6 +131,10 @@ class TorrentRemover(_PluginBase):
"torrentcategorys": self._torrentcategorys "torrentcategorys": self._torrentcategorys
}) })
if self._scheduler.get_jobs():
# 启动服务
self._scheduler.print_jobs()
self._scheduler.start()
def get_state(self) -> bool: def get_state(self) -> bool:
return True if self._enabled and self._cron and self._downloaders else False return True if self._enabled and self._cron and self._downloaders else False