Merge remote-tracking branch 'origin/pr_align_embedding_inputs_202411…

…12' into pr_align_embedding_inputs_20241112

comps/cores/proto/docarray.py

@@ -101,7 +101,7 @@ class EmbedDoc(BaseDoc):
     fetch_k: int = 20
     lambda_mult: float = 0.5
     score_threshold: float = 0.2
-    constraints: Optional[Union[Dict[str, Any], List[Dict[str, Any]],None]] = None
+    constraints: Optional[Union[Dict[str, Any], List[Dict[str, Any]], None]] = None
 
 
 class EmbedMultimodalDoc(EmbedDoc):

comps/embeddings/multimodal_clip/embedding_multimodal.py

@@ -4,6 +4,7 @@
 import datetime
 import time,os
 from typing import List, Optional, Union
+
 from dateparser.search import search_dates
 from embeddings_clip import vCLIP
 
@@ -23,9 +24,11 @@
     EmbeddingResponse,
     EmbeddingResponseData,
 )
+
 logger = CustomLogger("embedding_multimodal")
 logflag = os.getenv("LOGFLAG", False)
 
+
 def filtler_dates(prompt):
 
     base_date = datetime.datetime.today()
@@ -108,11 +111,13 @@ async def embedding(
         logger.info(res)
     return res
 
+
 async def get_embeddings(text: Union[str, List[str]]) -> List[List[float]]:
     texts = [text] if isinstance(text, str) else text
     embed_vector = embeddings.embed_query(texts).tolist()
     return embed_vector
 
+
 if __name__ == "__main__":
     embeddings = vCLIP({"model_name": "openai/clip-vit-base-patch32", "num_frm": 4})
     opea_microservices["opea_service@embedding_multimodal"].start()