Introduces new incremental response format

Replicates graphql/graphql-js@00e2b50

Author: Cito

docs/conf.py

@@ -147,6 +147,8 @@
 types.TracebackType
 TypeMap
 AwaitableOrValue
+DeferredFragmentRecord
+DeferUsage
 EnterLeaveVisitor
 ExperimentalIncrementalExecutionResults
 FieldGroup
@@ -165,18 +167,31 @@
 IncrementalResult
 InitialResultRecord
 Middleware
+StreamItemsRecord
+StreamRecord
 SubsequentDataRecord
 asyncio.events.AbstractEventLoop
-graphql.execution.collect_fields.FieldsAndPatches
+collections.abc.MutableMapping
+collections.abc.MutableSet
+graphql.execution.collect_fields.DeferUsage
+graphql.execution.collect_fields.CollectFieldsResult
+graphql.execution.collect_fields.FieldGroup
 graphql.execution.execute.StreamArguments
+graphql.execution.execute.StreamUsage
 graphql.execution.map_async_iterable.map_async_iterable
+graphql.execution.incremental_publisher.CompletedResult
 graphql.execution.incremental_publisher.DeferredFragmentRecord
+graphql.execution.incremental_publisher.DeferredGroupedFieldSetRecord
+graphql.execution.incremental_publisher.FormattedCompletedResult
 graphql.execution.incremental_publisher.IncrementalPublisher
 graphql.execution.incremental_publisher.InitialResultRecord
 graphql.execution.incremental_publisher.StreamItemsRecord
+graphql.execution.incremental_publisher.StreamRecord
 graphql.execution.Middleware
 graphql.language.lexer.EscapeSequence
 graphql.language.visitor.EnterLeaveVisitor
+graphql.pyutils.ref_map.K
+graphql.pyutils.ref_map.V
 graphql.type.definition.GT_co
 graphql.type.definition.GNT_co
 graphql.type.definition.TContext

docs/modules/pyutils.rst

@@ -30,3 +30,7 @@ PyUtils
 .. autoclass:: SimplePubSub
 .. autoclass:: SimplePubSubIterator
 .. autodata:: Undefined
+.. autoclass:: RefMap
+   :no-inherited-members:
+.. autoclass:: RefSet
+   :no-inherited-members:

pyproject.toml

@@ -320,6 +320,8 @@ timeout = "100"
 filterwarnings = "ignore::pytest.PytestConfigWarning"
 # All tests can be found in the tests directory.
 testpaths = ["tests"]
+# Use the functions scope as the default for asynchronous tests.
+asyncio_default_fixture_loop_scope = "function"
 
 [build-system]
 requires = ["poetry_core>=1.6.1,<2"]

src/graphql/execution/async_iterables.py

@@ -2,7 +2,7 @@
 
 from __future__ import annotations
 
-from contextlib import AbstractAsyncContextManager
+from contextlib import AbstractAsyncContextManager, suppress
 from typing import (
     AsyncGenerator,
     AsyncIterable,
@@ -20,6 +20,8 @@
 
 AsyncIterableOrGenerator = Union[AsyncGenerator[T, None], AsyncIterable[T]]
 
+suppress_exceptions = suppress(Exception)
+
 
 class aclosing(AbstractAsyncContextManager, Generic[T]):  # noqa: N801
     """Async context manager for safely finalizing an async iterator or generator.
@@ -40,7 +42,8 @@ async def __aexit__(self, *_exc_info: object) -> None:
         except AttributeError:
             pass  # do not complain if the iterator has no aclose() method
         else:
-            await aclose()
+            with suppress_exceptions:  # or if the aclose() method fails
+                await aclose()
 
 
 async def map_async_iterable(