infrastructure-vector-store-compati-opensearchvectorstore-is-used-as-the-vector-store--1d1bea9f

THEN Refactor OpensearchVectorStore to inherit from BasePydanticVectorStore, implementing the required methods such as `add` and `async_add`. This ensures compatibility with the IngestionPipeline.

class OpensearchVectorStore(BasePydanticVectorStore):
    stores_text = True
    flat_metadata = True

    def add(self, embedding_results: List[BaseNode]) -> List[str]:
        # implementation to add nodes to OpenSearch index
        ...

    async def async_add(self, embedding_results: List[BaseNode]) -> List[str]:
        # async equivalent
        ...