refactor: extract execution types to separate file

Replicates graphql/graphql-js@06bb157

Author: Cito

docs/conf.py

@@ -200,25 +200,25 @@
     "graphql.execution.execute.StreamArguments",
     "graphql.execution.execute.SubFieldPlan",
     "graphql.execution.execute.StreamUsage",
-    "graphql.execution.map_async_iterable.map_async_iterable",
-    "graphql.execution.incremental_publisher.BareDeferredGroupedFieldSetResult",
-    "graphql.execution.incremental_publisher.BareStreamItemsResult",
-    "graphql.execution.incremental_publisher.CancellableStreamRecord",
-    "graphql.execution.incremental_publisher.CompletedResult",
-    "graphql.execution.incremental_publisher.DeferredFragmentRecord",
-    "graphql.execution.incremental_publisher.DeferredGroupedFieldSetRecord",
-    "graphql.execution.incremental_publisher.FormattedCompletedResult",
-    "graphql.execution.incremental_publisher.FormattedPendingResult",
     "graphql.execution.incremental_publisher.IncrementalPublisher",
     "graphql.execution.incremental_publisher.IncrementalPublisherContext",
-    "graphql.execution.incremental_publisher.NonReconcilableStreamItemsResult",
-    "graphql.execution.incremental_publisher.PendingResult",
-    "graphql.execution.incremental_publisher.ReconcilableStreamItemsResult",
-    "graphql.execution.incremental_publisher.StreamItemsRecord",
-    "graphql.execution.incremental_publisher.StreamRecord",
-    "graphql.execution.incremental_publisher.SubsequentResultRecord",
-    "graphql.execution.incremental_publisher.TerminatingStreamItemsResult",
+    "graphql.execution.map_async_iterable.map_async_iterable",
     "graphql.execution.Middleware",
+    "graphql.execution.types.BareDeferredGroupedFieldSetResult",
+    "graphql.execution.types.BareStreamItemsResult",
+    "graphql.execution.types.CancellableStreamRecord",
+    "graphql.execution.types.CompletedResult",
+    "graphql.execution.types.DeferredFragmentRecord",
+    "graphql.execution.types.DeferredGroupedFieldSetRecord",
+    "graphql.execution.types.FormattedCompletedResult",
+    "graphql.execution.types.FormattedPendingResult",
+    "graphql.execution.types.NonReconcilableStreamItemsResult",
+    "graphql.execution.types.PendingResult",
+    "graphql.execution.types.ReconcilableStreamItemsResult",
+    "graphql.execution.types.StreamItemsRecord",
+    "graphql.execution.types.StreamRecord",
+    "graphql.execution.types.SubsequentResultRecord",
+    "graphql.execution.types.TerminatingStreamItemsResult",
     "graphql.language.lexer.EscapeSequence",
     "graphql.language.visitor.EnterLeaveVisitor",
     "graphql.pyutils.ref_map.K",

src/graphql/execution/__init__.py

@@ -4,19 +4,10 @@
 fulfilling a GraphQL request.
 """
 
-from .execute import (
-    create_source_event_stream,
-    execute,
-    experimental_execute_incrementally,
-    execute_sync,
-    default_field_resolver,
-    default_type_resolver,
-    subscribe,
-    ExecutionContext,
-    GraphQLWrappedResult,
-    Middleware,
-)
-from .incremental_publisher import (
+from .async_iterables import map_async_iterable
+from .types import (
+    CompletedResult,
+    DeferredFragmentRecord,
     ExecutionResult,
     ExperimentalIncrementalExecutionResults,
     FormattedSubsequentIncrementalExecutionResult,
@@ -25,17 +16,32 @@
     FormattedIncrementalStreamResult,
     FormattedExecutionResult,
     FormattedInitialIncrementalExecutionResult,
+    FormattedPendingResult,
     IncrementalDeferResult,
     IncrementalResult,
     IncrementalStreamResult,
     InitialIncrementalExecutionResult,
+    PendingResult,
     SubsequentIncrementalExecutionResult,
 )
-from .async_iterables import map_async_iterable
 from .middleware import MiddlewareManager
 from .values import get_argument_values, get_directive_values, get_variable_values
+from .execute import (
+    create_source_event_stream,
+    execute,
+    experimental_execute_incrementally,
+    execute_sync,
+    default_field_resolver,
+    default_type_resolver,
+    subscribe,
+    ExecutionContext,
+    GraphQLWrappedResult,
+    Middleware,
+)
 
 __all__ = [
+    "CompletedResult",
+    "DeferredFragmentRecord",
     "ExecutionContext",
     "ExecutionResult",
     "ExperimentalIncrementalExecutionResults",
@@ -44,6 +50,7 @@
     "FormattedIncrementalResult",
     "FormattedIncrementalStreamResult",
     "FormattedInitialIncrementalExecutionResult",
+    "FormattedPendingResult",
     "FormattedSubsequentIncrementalExecutionResult",
     "GraphQLWrappedResult",
     "IncrementalDeferResult",
@@ -52,6 +59,7 @@
     "InitialIncrementalExecutionResult",
     "Middleware",
     "MiddlewareManager",
+    "PendingResult",
     "SubsequentIncrementalExecutionResult",
     "create_source_event_stream",
     "default_field_resolver",

src/graphql/execution/execute.py

@@ -48,7 +48,7 @@
     inspect,
     is_iterable,
 )
-from ..pyutils import is_awaitable as default_is_awaitable
+from ..pyutils.is_awaitable import is_awaitable as default_is_awaitable
 from ..type import (
     GraphQLAbstractType,
     GraphQLField,
@@ -84,6 +84,11 @@
     collect_subfields,
 )
 from .incremental_publisher import (
+    IncrementalPublisherContext,
+    build_incremental_response,
+)
+from .middleware import MiddlewareManager
+from .types import (
     BareDeferredGroupedFieldSetResult,
     BareStreamItemsResult,
     CancellableStreamRecord,
@@ -93,7 +98,6 @@
     ExecutionResult,
     ExperimentalIncrementalExecutionResults,
     IncrementalDataRecord,
-    IncrementalPublisherContext,
     NonReconcilableDeferredGroupedFieldSetResult,
     NonReconcilableStreamItemsResult,
     ReconcilableDeferredGroupedFieldSetResult,
@@ -102,10 +106,8 @@
     StreamItemsResult,
     SubsequentResultRecord,
     TerminatingStreamItemsResult,
-    build_incremental_response,
     is_reconcilable_stream_items_result,
 )
-from .middleware import MiddlewareManager
 from .values import get_argument_values, get_directive_values, get_variable_values
 
 if TYPE_CHECKING:
@@ -119,6 +121,7 @@
 try:  # pragma: no cover
     anext  # noqa: B018  # pyright: ignore
 except NameError:  # pragma: no cover (Python < 3.10)
+
     async def anext(iterator: AsyncIterator) -> Any:
         """Return the next item from an async iterator."""
         return await iterator.__anext__()
@@ -644,6 +647,7 @@ def execute_field(
                 defer_map,
             )
             if self.is_awaitable(completed):
+
                 async def await_completed() -> Any:
                     try:
                         return await completed
@@ -1211,6 +1215,7 @@ def complete_list_item_value(
             )
 
             if is_awaitable(completed_item):
+
                 async def await_completed() -> Any:
                     try:
                         resolved = await completed_item  # type: ignore
@@ -2667,6 +2672,7 @@ def execute_subscription(
 
         result = resolve_fn(context.root_value, info, **args)
         if context.is_awaitable(result):
+
             async def await_result() -> AsyncIterable[Any]:
                 try:
                     return assert_event_stream(await result)