github/privateGPT
1
0
Fork 1
mirror of https://github.com/imartinez/privateGPT.git synced 2025-08-21 17:03:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: remove metadata from bulk ingestion

Browse Source
This commit is contained in:
Nathan Lenas 2024-07-23 09:34:16 +02:00
parent 50388f6a33
commit f47c05730d
1 changed files with 9 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
private_gpt/components/ingest/ingest_component.py
View File

@ -49,9 +49,7 @@ class BaseIngestComponent(abc.ABC):
pass
@abc.abstractmethod
def bulk_ingest(
self, files: list[tuple[str, Path]], metadata: dict[str, str] | None = None
) -> list[Document]:
def bulk_ingest(self, files: list[tuple[str, Path]]) -> list[Document]:
pass
@abc.abstractmethod
@ -140,13 +138,11 @@ class SimpleIngestComponent(BaseIngestComponentWithIndex):
logger.debug("Saving the documents in the index and doc store")
return self._save_docs(documents)
def bulk_ingest(
self, files: list[tuple[str, Path]], metadata: dict[str, str] | None = None
) -> list[Document]:
def bulk_ingest(self, files: list[tuple[str, Path]]) -> list[Document]:
saved_documents = []
for file_name, file_data in files:
documents = IngestionHelper.transform_file_into_documents(
file_name, file_data, metadata
file_name, file_data
)
saved_documents.extend(self._save_docs(documents))
return saved_documents
@ -207,16 +203,12 @@ class BatchIngestComponent(BaseIngestComponentWithIndex):
logger.debug("Saving the documents in the index and doc store")
return self._save_docs(documents)
def bulk_ingest(
self, files: list[tuple[str, Path]], metadata: dict[str, str] | None = None
) -> list[Document]:
def bulk_ingest(self, files: list[tuple[str, Path]]) -> list[Document]:
# Pair the files with the metadata
args = [(file_tuple, metadata) for file_tuple in files]
documents = list(
itertools.chain.from_iterable(
self._file_to_documents_work_pool.starmap(
IngestionHelper.transform_file_into_documents, args
IngestionHelper.transform_file_into_documents, files
)
)
)
@ -304,16 +296,13 @@ class ParallelizedIngestComponent(BaseIngestComponentWithIndex):
logger.debug("Saving the documents in the index and doc store")
return self._save_docs(documents)
def bulk_ingest(
self, files: list[tuple[str, Path]], metadata: dict[str, str] | None = None
) -> list[Document]:
def bulk_ingest(self, files: list[tuple[str, Path]]) -> list[Document]:
args = [(file_tuple, metadata) for file_tuple in files]
# Lightweight threads, used for parallelize the
# underlying IO calls made in the ingestion
documents = list(
itertools.chain.from_iterable(
self._ingest_work_pool.starmap(self.ingest, args)
self._ingest_work_pool.starmap(self.ingest, files)
)
)
return documents
@ -509,14 +498,12 @@ class PipelineIngestComponent(BaseIngestComponentWithIndex):
self._flush()
return documents
def bulk_ingest(
self, files: list[tuple[str, Path]], metadata: dict[str, str] | None = None
) -> list[Document]:
def bulk_ingest(self, files: list[tuple[str, Path]]) -> list[Document]:
docs = []
for file_name, file_data in eta(files):
try:
documents = IngestionHelper.transform_file_into_documents(
file_name, file_data, metadata
file_name, file_data
)
self.doc_q.put(("process", file_name, documents))
docs.extend(documents)