From 84b149d96aef179f405b7056f3a7708a7d4fd084 Mon Sep 17 00:00:00 2001 From: "jinli.yl" Date: Thu, 14 May 2026 14:37:28 +0800 Subject: [PATCH] up --- reme2/component/file_watcher/base_file_watcher.py | 1 + 1 file changed, 1 insertion(+) diff --git a/reme2/component/file_watcher/base_file_watcher.py b/reme2/component/file_watcher/base_file_watcher.py index b97242ca..144c852a 100644 --- a/reme2/component/file_watcher/base_file_watcher.py +++ b/reme2/component/file_watcher/base_file_watcher.py @@ -45,6 +45,7 @@ class BaseFileWatcher(BaseComponent): self._retry_interval: float = 10 async def _start(self): + self._stop_event = asyncio.Event() self.file_store = self.get_component(ComponentEnum.FILE_STORE, self.file_store_name) self.file_parser = self.get_component(ComponentEnum.FILE_PARSER, self.file_parser_name)