Fix DeprecationWarning's from elasticsearch-py.

Author: arnau126

Changelog.rst

@@ -3,6 +3,13 @@
 Changelog
 =========
 
+7.4.1 (?)
+------------------
+
+* Fixed DeprecationWarning from elasticsearch-py (`#1558_`)
+
+ .. _#1558: https://github.com/elastic/elasticsearch-dsl-py/pull/1558
+
 7.4.0 (2021-07-15)
 ------------------
 

README

@@ -80,22 +80,20 @@ Let's have a typical search request written directly as a ``dict``:
 
     response = client.search(
         index="my-index",
-        body={
-          "query": {
+        query={
             "bool": {
-              "must": [{"match": {"title": "python"}}],
-              "must_not": [{"match": {"description": "beta"}}],
-              "filter": [{"term": {"category": "search"}}]
+                "must": [{"match": {"title": "python"}}],
+                "must_not": [{"match": {"description": "beta"}}],
+                "filter": [{"term": {"category": "search"}}]
             }
-          },
-          "aggs" : {
+        },
+        aggs={
             "per_tag": {
-              "terms": {"field": "tags"},
-              "aggs": {
-                "max_lines": {"max": {"field": "lines"}}
-              }
+                "terms": {"field": "tags"},
+                "aggs": {
+                    "max_lines": {"max": {"field": "lines"}}
+                }
             }
-          }
         }
     )
 

elasticsearch_dsl/document.py

@@ -484,7 +484,7 @@ def save(
         doc_meta.update(kwargs)
         meta = es.index(
             index=self._get_index(index),
-            body=self.to_dict(skip_empty=skip_empty),
+            document=self.to_dict(skip_empty=skip_empty),
             **doc_meta
         )
         # update meta information from ES

elasticsearch_dsl/index.py

@@ -277,7 +277,7 @@ def create(self, using=None, **kwargs):
         ``Elasticsearch.indices.create`` unchanged.
         """
         return self._get_connection(using).indices.create(
-            index=self._name, body=self.to_dict(), **kwargs
+            index=self._name, **self.to_dict(), **kwargs
         )
 
     def is_closed(self, using=None):

elasticsearch_dsl/search.py

@@ -712,7 +712,7 @@ def execute(self, ignore_cache=False):
             es = get_connection(self._using)
 
             self._response = self._response_class(
-                self, es.search(index=self._index, body=self.to_dict(), **self._params)
+                self, es.search(index=self._index, **self.to_dict(), **self._params)
             )
         return self._response