From 409fcf2015bcae4182b3d6e5fed22acd297c82fd Mon Sep 17 00:00:00 2001 From: zhangxunhui Date: Mon, 26 Jan 2026 09:53:30 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BA=86document=20exists?= =?UTF-8?q?=E8=B0=83=E7=94=A8=E7=9A=84=E5=88=A4=E6=96=AD=E9=80=BB=E8=BE=91?= =?UTF-8?q?=EF=BC=8C=E4=BB=8Edoc=5Fid=E5=8F=98=E6=88=90=E4=BA=86doc=5Fid?= =?UTF-8?q?=5Fchunk=5F0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sync/folder_sync.py | 5 +++-- sync_service.py | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/sync/folder_sync.py b/sync/folder_sync.py index 26505ab..0abe12a 100644 --- a/sync/folder_sync.py +++ b/sync/folder_sync.py @@ -14,7 +14,7 @@ from llama_index.core import Document class FolderSync(BaseSync): """Handle synchronization between folder (local or remote) and ChromaDB""" - def __init__(self, config: BaseDataSourceConfig): + def __init__(self, config: BaseDataSourceConfig, vector_store_manager=None): """ Initialize folder sync with configuration @@ -25,6 +25,7 @@ class FolderSync(BaseSync): self.file_parser = FileParser() self._ssh_client = None self._sftp_client = None + self.vector_store_manager = vector_store_manager def fetch_all_documents(self, last_sync_time=None) -> List[Dict[str, Any]]: """ @@ -55,7 +56,7 @@ class FolderSync(BaseSync): if last_sync_time is not None: # Check if document has already been synced - if self.vector_store_manager and self.vector_store_manager.document_exists(doc_id): + if self.vector_store_manager and self.vector_store_manager.document_exists(doc_id + "_chunk_0"): # If document is already synced, check if it's been modified since last sync if last_sync_time: file_stat = self._sftp_client.stat(file_path) diff --git a/sync_service.py b/sync_service.py index 5cb55ed..07cd9e0 100644 --- a/sync_service.py +++ b/sync_service.py @@ -51,7 +51,7 @@ class SyncService: sync_class = get_sync_class(self.source_config.type) # Create a new syncer instance for this data source - self.syncer = sync_class(self.source_config, vector_store_manager=self.vector_store_manager) + self.syncer = sync_class(self.source_config, self.vector_store_manager) # Initialize sync tracking data self.last_sync_time = None