Properly await wrapped async call in elasticsearch (#1725)

* Properly await wrapped async call in elasticsearch

* CHANGELOG

Author: basepi

CHANGELOG.asciidoc

@@ -38,8 +38,10 @@ endif::[]
 
 * GRPC support {pull}1703[#1703]
 
-//[float]
-//===== Bug fixes
+[float]
+===== Bug fixes
+
+* Fix an async issue with long elasticsearch queries {pull}1725[#1725]
 
 
 [[release-notes-6.x]]

elasticapm/instrumentation/packages/asyncio/elasticsearch.py

@@ -56,7 +56,7 @@ def get_instrument_list(self):
     async def call(self, module, method, wrapped, instance, args, kwargs):
         span = execution_context.get_span()
         if not span or isinstance(span, DroppedSpan):
-            return wrapped(*args, **kwargs)
+            return await wrapped(*args, **kwargs)
 
         self._update_context_by_request_data(span.context, instance, args, kwargs)