Coverage for src / qdrant_loader / connectors / factory.py: 100%

1from typing import Any 

2 

3from .registry import CONNECTOR_REGISTRY 

4 

5 

6def get_connector_instance(config: Any) -> Any: 

7 """Create and return a connector instance based on the config's source and deployment type.""" 

8 key = (config.source_type, getattr(config, "deployment_type", None)) 

9 

10 connector_class = CONNECTOR_REGISTRY.get(key) 

11 

12 if not connector_class: 

13 raise ValueError(f"Unsupported connector type: {key}") 

14 

15 return connector_class(config)