Fix refresh behaviour for Elasticsearch delete (deepset-ai#794)

psorianom · Feb 1, 2021 · 5bf351e · 5bf351e
1 parent d62355c
commit 5bf351e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/haystack/document_store/elasticsearch.py b/haystack/document_store/elasticsearch.py
@@ -780,7 +780,8 @@ def delete_all_documents(self, index: Optional[str] = None, filters: Optional[Di
             query["query"] = {"match_all": {}}
         self.client.delete_by_query(index=index, body=query, ignore=[404])
         # We want to be sure that all docs are deleted before continuing (delete_by_query doesn't support wait_for)
-        time.sleep(1)
+        if self.refresh_type == "wait_for":
+            time.sleep(1)
 
 
 class OpenDistroElasticsearchDocumentStore(ElasticsearchDocumentStore):