revert Protocol change because Python 3.7

Author: maxjakob

elasticsearch/helpers/vectorstore/_async/embedding_service.py

@@ -15,12 +15,14 @@
 #  specific language governing permissions and limitations
 #  under the License.
 
-from typing import List, Optional, Protocol
+from abc import ABC, abstractmethod
+from typing import List, Optional
 
 from elasticsearch import AsyncElasticsearch
 
 
-class AsyncEmbeddingService(Protocol):
+class AsyncEmbeddingService(ABC):
+    @abstractmethod
     async def embed_documents(self, texts: List[str]) -> List[List[float]]:
         """Generate embeddings for a list of documents.
 
@@ -31,6 +33,7 @@ async def embed_documents(self, texts: List[str]) -> List[List[float]]:
             A list of embeddings, one for each document in the input.
         """
 
+    @abstractmethod
     async def embed_query(self, query: str) -> List[float]:
         """Generate an embedding for a single query text.
 

elasticsearch/helpers/vectorstore/_async/strategies.py

@@ -15,14 +15,16 @@
 #  specific language governing permissions and limitations
 #  under the License.
 
-from typing import Any, Dict, List, Optional, Protocol, Tuple, Union, cast
+from abc import ABC, abstractmethod
+from typing import Any, Dict, List, Optional, Tuple, Union, cast
 
 from elasticsearch import AsyncElasticsearch
 from elasticsearch.helpers.vectorstore._async._utils import model_must_be_deployed
 from elasticsearch.helpers.vectorstore._utils import DistanceMetric
 
 
-class AsyncRetrievalStrategy(Protocol):
+class AsyncRetrievalStrategy(ABC):
+    @abstractmethod
     def es_query(
         self,
         query: Optional[str],
@@ -48,6 +50,7 @@ def es_query(
             Dict: The Elasticsearch query body.
         """
 
+    @abstractmethod
     def es_mappings_settings(
         self,
         text_field: str,

elasticsearch/helpers/vectorstore/_sync/embedding_service.py

@@ -15,12 +15,14 @@
 #  specific language governing permissions and limitations
 #  under the License.
 
-from typing import List, Optional, Protocol
+from abc import ABC, abstractmethod
+from typing import List, Optional
 
 from elasticsearch import Elasticsearch
 
 
-class EmbeddingService(Protocol):
+class EmbeddingService(ABC):
+    @abstractmethod
     def embed_documents(self, texts: List[str]) -> List[List[float]]:
         """Generate embeddings for a list of documents.
 
@@ -31,6 +33,7 @@ def embed_documents(self, texts: List[str]) -> List[List[float]]:
             A list of embeddings, one for each document in the input.
         """
 
+    @abstractmethod
     def embed_query(self, query: str) -> List[float]:
         """Generate an embedding for a single query text.
 

elasticsearch/helpers/vectorstore/_sync/strategies.py

@@ -15,14 +15,16 @@
 #  specific language governing permissions and limitations
 #  under the License.
 
-from typing import Any, Dict, List, Optional, Protocol, Tuple, Union, cast
+from abc import ABC, abstractmethod
+from typing import Any, Dict, List, Optional, Tuple, Union, cast
 
 from elasticsearch import Elasticsearch
 from elasticsearch.helpers.vectorstore._sync._utils import model_must_be_deployed
 from elasticsearch.helpers.vectorstore._utils import DistanceMetric
 
 
-class RetrievalStrategy(Protocol):
+class RetrievalStrategy(ABC):
+    @abstractmethod
     def es_query(
         self,
         query: Optional[str],
@@ -48,6 +50,7 @@ def es_query(
             Dict: The Elasticsearch query body.
         """
 
+    @abstractmethod
     def es_mappings_settings(
         self,
         text_field: str,