Add delete_by_query wrapper which was missing

apache · Apr 24, 2019 · c7f496e · c7f496e
1 parent d718dde
commit c7f496e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/api/plugins/database.py b/api/plugins/database.py
@@ -47,6 +47,8 @@ def update(self, index, doc_type, id, body):
         return self.ES.update(index = index+'_'+doc_type, doc_type = '_doc', id = id, body = body)
     def scroll(self, scroll_id, scroll):
         return self.ES.scroll(scroll_id = scroll_id, scroll = scroll)
+    def delete_by_query(self, **kwargs):
+        return self.ES.delete_by_query(**kwargs)
     def search(self, index, doc_type, size = 100, scroll = None, _source_include = None, body = None):
         return self.ES.search(
             index = index+'_'+doc_type,