Await in parallel

Author: mawa

graphql/execution/execute.py

@@ -1,3 +1,4 @@
+from asyncio import gather
 from inspect import isawaitable
 from typing import (
     Any,
@@ -427,6 +428,7 @@ def execute_fields(
             )
             if result is not INVALID:
                 results[response_name] = result
+
                 if not is_async and isawaitable(result):
                     is_async = True
 
@@ -437,11 +439,18 @@ def execute_fields(
         # Otherwise, results is a map from field name to the result of
         # resolving that field, which is possibly a coroutine object.
         # Return a coroutine object that will yield this same map, but with
-        # any coroutines awaited and replaced with the values they yielded.
+        # any coroutines awaited in parallel and replaced with the values they
+        # yielded.
         async def get_results():
+            async def await_kv(key, value):
+                return key, await value if isawaitable(value) else value
+
             return {
-                key: await value if isawaitable(value) else value
-                for key, value in results.items()
+                key: value
+                for key, value in await gather(
+                    *(await_kv(key, value) for key, value in results.items()),
+                    return_exceptions=True,
+                )
             }
 
         return get_results()