Update es

2 years ago · 1e9f18c58f
1 changed files with 1 additions and 3 deletions
--- a/es_search.py
+++ b/es_search.py
@ -33,9 +33,7 @@ class ESSearch(PyOperator):
            logger.error('Failed to connect ElasticSearch client:\n', e)
            raise e
    def __call__(self, index_name: str, query: dict = {'match_all': {}}, enable: bool=True):
        if not enable:
            return ''
    def __call__(self, index_name: str, query: dict = {'match_all': {}}):
        resp = self.client.search(index=index_name, query=query)
        return resp