thsrite/archived-MoviePilot-Plugins
1
0
Fork 0
mirror of https://github.com/thsrite/MoviePilot-Plugins.git synced 2026-03-27 10:05:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

更新等待时间接口

Browse Source
This commit is contained in:
sleikang
2024-11-10 12:21:32 +08:00
parent 8dd34da532
commit 6e2d381b5d
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
plugins.v2/filesoftlink/__init__.py
View File

@@ -4,7 +4,7 @@ import re
import shutil
import threading
import traceback
import time
import asyncio
from pathlib import Path
from typing import List, Tuple, Dict, Any, Optional
@@ -423,7 +423,7 @@ class FileSoftLink(_PluginBase):
event_path=str(src_file),
mon_path=mon_path,
)
time.sleep(self._sync_interval)
asyncio.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
@@ -469,7 +469,7 @@ class FileSoftLink(_PluginBase):
event_path=str(src_file), mon_path=mon_path
)
logger.info(f"等待 {self._sync_interval} 秒")
time.sleep(self._sync_interval)
asyncio.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
channel=event.event_data.get("channel"),
@@ -492,7 +492,7 @@ class FileSoftLink(_PluginBase):
event_path=str(src_file), mon_path=mon_path
)
logger.info(f"等待 {self._sync_interval} 秒")
time.sleep(self._sync_interval)
asyncio.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
channel=event.event_data.get("channel"),
@@ -532,7 +532,7 @@ class FileSoftLink(_PluginBase):
if Path(src_file).is_file():
self.__handle_file(event_path=str(src_file), mon_path=mon_path)
logger.info(f"等待 {self._sync_interval} 秒")
time.sleep(self._sync_interval)
asyncio.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
channel=event.event_data.get("channel"),
@@ -572,7 +572,7 @@ class FileSoftLink(_PluginBase):
if Path(path).is_file():
self.__handle_file(event_path=str(path), mon_path=mon_path)
logger.info(f"等待 {self._sync_interval} 秒")
time.sleep(self._sync_interval)
asyncio.sleep(self._sync_interval)
logger.info("全量同步监控目录完成！")
except Exception as result:
logger.error(f"全量同步监控目录失败：{result}")