acompress_documents() — langchain Function Reference
Architecture documentation for the acompress_documents() function in base.py from the langchain codebase.
Entity Profile
Dependency Diagram
graph TD 2ce8d6b5_e110_4c27_3916_1e67efea2cfb["acompress_documents()"] fe1f22c7_98da_054f_3979_844dfb23684e["DocumentCompressorPipeline"] 2ce8d6b5_e110_4c27_3916_1e67efea2cfb -->|defined in| fe1f22c7_98da_054f_3979_844dfb23684e style 2ce8d6b5_e110_4c27_3916_1e67efea2cfb fill:#6366f1,stroke:#818cf8,color:#fff
Relationship Graph
Source Code
libs/langchain/langchain_classic/retrievers/document_compressors/base.py lines 53–81
async def acompress_documents(
self,
documents: Sequence[Document],
query: str,
callbacks: Callbacks | None = None,
) -> Sequence[Document]:
"""Compress retrieved documents given the query context."""
for _transformer in self.transformers:
if isinstance(_transformer, BaseDocumentCompressor):
accepts_callbacks = (
signature(_transformer.acompress_documents).parameters.get(
"callbacks",
)
is not None
)
if accepts_callbacks:
documents = await _transformer.acompress_documents(
documents,
query,
callbacks=callbacks,
)
else:
documents = await _transformer.acompress_documents(documents, query)
elif isinstance(_transformer, BaseDocumentTransformer):
documents = await _transformer.atransform_documents(documents)
else:
msg = f"Got unexpected transformer type: {_transformer}" # type: ignore[unreachable]
raise ValueError(msg) # noqa: TRY004
return documents
Domain
Subdomains
Source
Frequently Asked Questions
What does acompress_documents() do?
acompress_documents() is a function in the langchain codebase, defined in libs/langchain/langchain_classic/retrievers/document_compressors/base.py.
Where is acompress_documents() defined?
acompress_documents() is defined in libs/langchain/langchain_classic/retrievers/document_compressors/base.py at line 53.
Analyze Your Own Codebase
Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.
Try Supermodel Free