feat: Adding support Multimodal embedders.

Author: awais786

tests/client/test_multimodal.py

@@ -5,7 +5,9 @@
 
 import pytest
 import requests
+
 from meilisearch import Client
+from meilisearch.errors import MeilisearchApiError
 from tests import common
 
 # ---------------- ENV ----------------
@@ -146,7 +148,8 @@ def clear_indexes(self, client):
                 try:
                     task = client.index(index.uid).delete()
                     client.wait_for_task(task.task_uid)
-                except Exception:
+                except (MeilisearchApiError, Exception):  # pylint: disable=broad-exception-caught
+                    # Ignore errors when deleting indexes (may not exist)
                     pass
 
     @pytest.fixture(scope="class", autouse=True)
@@ -161,7 +164,7 @@ def setup_index(self, request):
         try:
             task = client.index(INDEX_UID).delete()
             client.wait_for_task(task.task_uid)
-        except Exception:
+        except MeilisearchApiError:
             pass  # Index doesn't exist, which is fine
 
         # Create index
@@ -185,38 +188,26 @@ def setup_index(self, request):
                 "Content-Type": "application/json",
             },
             json=settings_payload,
+            timeout=30,
         )
         response.raise_for_status()
 
         # Wait for settings update task (embedder config can take longer)
         task_data = response.json()
         task_uid = task_data.get("taskUid")
-        if task_uid:
-            task = client.wait_for_task(
-                task_uid, timeout_in_ms=60_000
-            )  # 1 minute for embedder setup
-            if task.status != "succeeded":
-                error_msg = f"Embedder setup failed: status={task.status}"
-                if task.error:
-                    error_msg += f", error={task.error}"
-                raise Exception(error_msg)
+        client.wait_for_task(task_uid, timeout_in_ms=60_000)
 
         index = client.get_index(INDEX_UID)
 
         # Add documents
         task = index.add_documents(MOVIES)
         # Use longer timeout for document indexing with embeddings
         # Each document needs embeddings generated via Voyage API, which can be slow
-        task = client.wait_for_task(
+        client.wait_for_task(
             task.task_uid,
             timeout_in_ms=300_000,  # 5 minutes timeout for embedding generation
             interval_in_ms=1000,  # Poll every 1 second instead of 50ms to reduce log noise
         )
-        if task.status != "succeeded":
-            error_msg = f"Document indexing failed: status={task.status}"
-            if task.error:
-                error_msg += f", error={task.error}"
-            raise Exception(error_msg)
 
         # Verify index is ready by checking stats
         stats = index.get_stats()
@@ -229,7 +220,7 @@ def setup_index(self, request):
         request.cls.index = index
         request.cls.search_client = Client(common.BASE_URL, common.MASTER_KEY)  # Search client
 
-    def test_text_query(self):
+    def test_text_query(self):  # pylint: disable=no-member
         """Test text query search"""
         query = "The story follows Carol Danvers"
         response = self.search_client.index(INDEX_UID).search(
@@ -248,7 +239,7 @@ def test_text_query(self):
         )
         assert response["hits"][0]["title"] == "Captain Marvel"
 
-    def test_image_query(self):
+    def test_image_query(self):  # pylint: disable=no-member
         """Test image query search"""
         # Find Dumbo in the movies list
         dumbo_movie = next(m for m in MOVIES if m["title"] == "Dumbo")
@@ -270,7 +261,7 @@ def test_image_query(self):
         )
         assert response["hits"][0]["title"] == "Dumbo"
 
-    def test_text_and_image_query(self):
+    def test_text_and_image_query(self):  # pylint: disable=no-member
         """Test text and image query"""
         query = "a futuristic movie"
         master_yoda_base64 = load_image_base64("master-yoda.jpeg")