Re-align incremental delivery with the WorkQueue architecture

docs/modules/pyutils.rst

@@ -24,7 +24,6 @@ PyUtils
 .. autoclass:: AbortSignal
 .. autoexception:: AbortError
 .. autoclass:: AwaitableOrValue
-.. autoclass:: BoxedAwaitableOrValue
 .. autofunction:: suggestion_list
 .. autoclass:: FrozenError
    :no-members:

pyproject.toml

@@ -149,6 +149,7 @@ ignore = [
    "I001",  # imports do not need to be sorted
 ]
 "src/graphql/execution/*" = [
+    "ARG002",  # allow unused arguments in overridable hook methods
     "BLE001",  # allow catching blind exception
 ]
 "src/graphql/language/ast.py" = [

src/graphql/execution/__init__.py

@@ -8,7 +8,6 @@
 from .async_iterables import map_async_iterable
 from .types import (
     CompletedResult,
-    DeferredFragmentRecord,
     ExecutionResult,
     ExperimentalIncrementalExecutionResults,
     FormattedSubsequentIncrementalExecutionResult,
@@ -24,10 +23,6 @@
     InitialIncrementalExecutionResult,
     PendingResult,
     SubsequentIncrementalExecutionResult,
-    StreamRecord,
-    StreamItemRecord,
-    StreamItemResult,
-    StreamItemsResult,
 )
 from .middleware import MiddlewareManager
 from .values import (
@@ -50,7 +45,6 @@
     AsyncWorkFinishedInfo,
     ExecutionHooks,
     Executor,
-    GraphQLWrappedResult,
     Middleware,
     RootSelectionSetExecutor,
 )
@@ -59,7 +53,6 @@
     "AbortedGraphQLExecutionError",
     "AsyncWorkFinishedInfo",
     "CompletedResult",
-    "DeferredFragmentRecord",
     "ExecutionHooks",
     "ExecutionResult",
     "Executor",
@@ -71,7 +64,6 @@
     "FormattedInitialIncrementalExecutionResult",
     "FormattedPendingResult",
     "FormattedSubsequentIncrementalExecutionResult",
-    "GraphQLWrappedResult",
     "IncrementalDeferResult",
     "IncrementalResult",
     "IncrementalStreamResult",
@@ -80,10 +72,6 @@
     "MiddlewareManager",
     "PendingResult",
     "RootSelectionSetExecutor",
-    "StreamItemRecord",
-    "StreamItemResult",
-    "StreamItemsResult",
-    "StreamRecord",
     "SubsequentIncrementalExecutionResult",
     "VariableValues",
     "create_source_event_stream",

src/graphql/execution/collect_fields.py

@@ -12,7 +12,6 @@
     FragmentSpreadNode,
     InlineFragmentNode,
     OperationDefinitionNode,
-    OperationType,
     SelectionSetNode,
 )
 from ..type import (
@@ -201,7 +200,7 @@ def collect_fields_impl(
         schema,
         fragments,
         variable_values,
-        operation,
+        _operation,
         runtime_type,
         visited_fragment_names,
         hide_suggestions,
@@ -226,7 +225,6 @@ def collect_fields_impl(
                 continue
 
             new_defer_usage = get_defer_usage(
-                operation,
                 variable_values,
                 fragment_variable_values,
                 selection,
@@ -267,7 +265,6 @@ def collect_fields_impl(
                 continue
 
             new_defer_usage = get_defer_usage(
-                operation,
                 variable_values,
                 fragment_variable_values,
                 selection,
@@ -315,7 +312,6 @@ def collect_fields_impl(
 
 
 def get_defer_usage(
-    operation: OperationDefinitionNode,
     variable_values: VariableValues,
     fragment_variable_values: FragmentVariableValues | None,
     node: FragmentSpreadNode | InlineFragmentNode,
@@ -334,13 +330,6 @@ def get_defer_usage(
     if not defer or defer.get("if") is False:
         return None
 
-    if operation.operation == OperationType.SUBSCRIPTION:
-        msg = (
-            "`@defer` directive not supported on subscription operations."
-            " Disable `@defer` by setting the `if` argument to `false`."
-        )
-        raise TypeError(msg)
-
     return DeferUsage(defer.get("label"), parent_defer_usage)