docarray
diff --git a/‎.github/workflows/add_license.yml
Copy file name to clipboardExpand all lines: .github/workflows/add_license.yml
+1-1Lines changed: 1 addition & 1 deletion b/‎.github/workflows/add_license.yml
Copy file name to clipboardExpand all lines: .github/workflows/add_license.yml
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎.github/workflows/ci.yml
Copy file name to clipboardExpand all lines: .github/workflows/ci.yml
+7-7Lines changed: 7 additions & 7 deletions b/‎.github/workflows/ci.yml
Copy file name to clipboardExpand all lines: .github/workflows/ci.yml
+7-7Lines changed: 7 additions & 7 deletions
diff --git a/‎docarray/index/backends/helper.py
Copy file name to clipboardExpand all lines: docarray/index/backends/helper.py
+38-1Lines changed: 38 additions & 1 deletion b/‎docarray/index/backends/helper.py
Copy file name to clipboardExpand all lines: docarray/index/backends/helper.py
+38-1Lines changed: 38 additions & 1 deletion
@@ -15,7 +15,7 @@ jobs:
       - name: Set up Python
         uses: actions/setup-python@v3
         with:
-          python-version: 3.10
+          python-version: "3.10"
 
       - name: Run add_license.sh and check for changes
         id: add_license
 
@@ -119,7 +119,7 @@ jobs:
       - name: Test
         id: test
         run: |
-          poetry run pytest -m "not (tensorflow or benchmark or index or jax)" --cov=docarray --cov-report=xml ${{ matrix.test-path }} --ignore=tests/integrations/store/test_jac.py
+          poetry run pytest -m "not (tensorflow or benchmark or index or jax)" --cov=docarray --cov-report=xml -v -s ${{ matrix.test-path }} --ignore=tests/integrations/store/test_jac.py
           echo "flag it as docarray for codeoverage"
           echo "codecov_flag=docarray" >> $GITHUB_OUTPUT
         timeout-minutes: 30
@@ -167,7 +167,7 @@ jobs:
       - name: Test
         id: test
         run: |
-          poetry run pytest -m 'proto' --cov=docarray --cov-report=xml tests
+          poetry run pytest -m 'proto' --cov=docarray --cov-report=xml -v -s tests
           echo "flag it as docarray for codeoverage"
           echo "codecov_flag=docarray" >> $GITHUB_OUTPUT
         timeout-minutes: 30
@@ -217,7 +217,7 @@ jobs:
       - name: Test
         id: test
         run: |
-          poetry run pytest -m 'index and not elasticv8' --cov=docarray --cov-report=xml tests/index/${{ matrix.db_test_folder }}
+          poetry run pytest -m 'index and not elasticv8' --cov=docarray --cov-report=xml -v -s tests/index/${{ matrix.db_test_folder }}
           echo "flag it as docarray for codeoverage"
           echo "codecov_flag=docarray" >> $GITHUB_OUTPUT
         timeout-minutes: 30
@@ -267,7 +267,7 @@ jobs:
       - name: Test
         id: test
         run: |
-          poetry run pytest -m 'index and elasticv8' --cov=docarray --cov-report=xml tests
+          poetry run pytest -m 'index and elasticv8' --cov=docarray --cov-report=xml -v -s tests
           echo "flag it as docarray for codeoverage"
           echo "codecov_flag=docarray" >> $GITHUB_OUTPUT
         timeout-minutes: 30
@@ -316,7 +316,7 @@ jobs:
       - name: Test
         id: test
         run: |
-          poetry run pytest -m 'tensorflow' --cov=docarray --cov-report=xml tests
+          poetry run pytest -m 'tensorflow' --cov=docarray --cov-report=xml -v -s tests
           echo "flag it as docarray for codeoverage"
           echo "codecov_flag=docarray" >> $GITHUB_OUTPUT
         timeout-minutes: 30
@@ -362,7 +362,7 @@ jobs:
       - name: Test
         id: test
         run: |
-          poetry run pytest -m 'jax' --cov=docarray --cov-report=xml tests
+          poetry run pytest -m 'jax' --cov=docarray --cov-report=xml -v -s tests
           echo "flag it as docarray for codeoverage"
           echo "codecov_flag=docarray" >> $GITHUB_OUTPUT
         timeout-minutes: 30
@@ -406,7 +406,7 @@ jobs:
       - name: Test
         id: test
         run: |
-          poetry run pytest -m 'benchmark' --cov=docarray --cov-report=xml tests
+          poetry run pytest -m 'benchmark' --cov=docarray --cov-report=xml -v -s tests
           echo "flag it as docarray for codeoverage"
           echo "codecov_flag=docarray" >> $GITHUB_OUTPUT
         timeout-minutes: 30
 
@@ -1,4 +1,4 @@
-from typing import Any, Dict, List, Tuple, Type, cast
+from typing import Any, Dict, List, Tuple, Type, cast, Set
 
 from docarray import BaseDoc, DocList
 from docarray.index.abstract import BaseDocIndex
@@ -20,6 +20,43 @@ def inner(self, *args, **kwargs):
     return inner
 
 
+def _collect_query_required_args(method_name: str, required_args: Set[str] = None):
+    """
+    Returns a function that ensures required keyword arguments are provided.
+
+    :param method_name: The name of the method for which the required arguments are being checked.
+    :type method_name: str
+    :param required_args: A set containing the names of required keyword arguments. Defaults to None.
+    :type required_args: Optional[Set[str]]
+    :return: A function that checks for required keyword arguments before executing the specified method.
+        Raises ValueError if positional arguments are provided.
+        Raises TypeError if any required keyword argument is missing.
+    :rtype: Callable
+    """
+
+    if required_args is None:
+        required_args = set()
+
+    def inner(self, *args, **kwargs):
+        if args:
+            raise ValueError(
+                f"Positional arguments are not supported for "
+                f"`{type(self)}.{method_name}`. "
+                f"Use keyword arguments instead."
+            )
+
+        missing_args = required_args - set(kwargs.keys())
+        if missing_args:
+            raise ValueError(
+                f"`{type(self)}.{method_name}` is missing required argument(s): {', '.join(missing_args)}"
+            )
+
+        updated_query = self._queries + [(method_name, kwargs)]
+        return type(self)(updated_query)
+
+    return inner
+
+
 def _execute_find_and_filter_query(
     doc_index: BaseDocIndex, query: List[Tuple[str, Dict]], reverse_order: bool = False
 ) -> FindResult: