Coverage for src/qdrant_loader/core/pipeline/__init__.py: 100%

1"""Pipeline components for the async ingestion pipeline.""" 

2 

3from .config import PipelineConfig 

4from .document_pipeline import DocumentPipeline 

5from .factory import PipelineComponentsFactory 

6from .orchestrator import PipelineComponents, PipelineOrchestrator 

7from .resource_manager import ResourceManager 

8from .source_filter import SourceFilter 

9from .source_processor import SourceProcessor 

10from .workers import BaseWorker, ChunkingWorker, EmbeddingWorker, UpsertWorker 

11from .workers.upsert_worker import PipelineResult 

12 

13__all__ = [ 

14 "PipelineConfig", 

15 "DocumentPipeline", 

16 "PipelineComponents", 

17 "PipelineComponentsFactory", 

18 "PipelineOrchestrator", 

19 "ResourceManager", 

20 "SourceFilter", 

21 "SourceProcessor", 

22 "BaseWorker", 

23 "ChunkingWorker", 

24 "EmbeddingWorker", 

25 "UpsertWorker", 

26 "PipelineResult", 

27]