Fix for list inputs

Signed-off-by: Jael Gu <mengjia.gu@zilliz.com>
3 years ago · 15c8f0c14c
1 changed files with 3 additions and 0 deletions
--- a/es_index.py
+++ b/es_index.py
@ -38,6 +38,9 @@ class ESIndex(PyOperator):
    def __call__(self, doc: Union[dict, List[dict]]):
        if isinstance(doc, dict):
            docs = [doc]
        else:
            docs = doc
        for x in docs:
            assert isinstance(x, dict)