diff --git a/packages/leann-backend-diskann/leann_backend_diskann/diskann_embedding_server.py b/packages/leann-backend-diskann/leann_backend_diskann/diskann_embedding_server.py index 1d042fd..f6c3825 100644 --- a/packages/leann-backend-diskann/leann_backend_diskann/diskann_embedding_server.py +++ b/packages/leann-backend-diskann/leann_backend_diskann/diskann_embedding_server.py @@ -80,6 +80,7 @@ def create_diskann_embedding_server( with open(passages_file) as f: meta = json.load(f) + logger.info(f"Loading PassageManager with metadata_file_path: {passages_file}") passages = PassageManager(meta["passage_sources"], metadata_file_path=passages_file) logger.info( f"Loaded PassageManager with {len(passages.global_offset_map)} passages from metadata" diff --git a/packages/leann-backend-diskann/third_party/DiskANN b/packages/leann-backend-diskann/third_party/DiskANN index c73bcec..b2dc4ea 160000 --- a/packages/leann-backend-diskann/third_party/DiskANN +++ b/packages/leann-backend-diskann/third_party/DiskANN @@ -1 +1 @@ -Subproject commit c73bcec98c956181602f42b94f00d6a24388c1f2 +Subproject commit b2dc4ea2c7e52e8a6481d3ba10003e192192a7b7 diff --git a/packages/leann-core/src/leann/api.py b/packages/leann-core/src/leann/api.py index 25091f4..74562bc 100644 --- a/packages/leann-core/src/leann/api.py +++ b/packages/leann-core/src/leann/api.py @@ -132,12 +132,21 @@ class PassageManager: if metadata_file_path: # Resolve relative to metadata file directory metadata_dir = Path(metadata_file_path).parent + logger.debug( + f"PassageManager: Resolving relative paths from metadata_dir: {metadata_dir}" + ) index_file = str((metadata_dir / index_file).resolve()) passage_file = str((metadata_dir / passage_file).resolve()) + logger.debug(f"PassageManager: Resolved index_file: {index_file}") else: # Fallback to current directory resolution (legacy behavior) + logger.warning( + "PassageManager: No metadata_file_path provided, using fallback resolution from cwd" + ) + logger.debug(f"PassageManager: Current working directory: {Path.cwd()}") index_file = str(Path(index_file).resolve()) passage_file = str(Path(passage_file).resolve()) + logger.debug(f"PassageManager: Fallback resolved index_file: {index_file}") if not Path(index_file).exists(): raise FileNotFoundError(f"Passage index file not found: {index_file}")