We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0dd2c5a commit 2c169daCopy full SHA for 2c169da
1 file changed
src/graphql/execution/execute.py
@@ -233,7 +233,6 @@ def __init__(
233
self.is_async_iterable = is_async_iterable or default_is_async_iterable
234
self.errors = None
235
self.cancellable_streams = None
236
- self._canceled_iterators: set[AsyncIterator] = set()
237
self._relevant_sub_fields: dict[tuple, CollectedFields] = {}
238
self._stream_usages: RefMap[FieldGroup, StreamUsage] = RefMap()
239
self._execution_plans: RefMap[GroupedFieldSet, ExecutionPlan] = RefMap()
@@ -964,7 +963,6 @@ async def complete_async_iterator_value(
964
963
if self.cancellable_streams is None: # pragma: no branch
965
self.cancellable_streams = set()
966
self.cancellable_streams.add(stream_record)
967
- self._canceled_iterators.add(async_iterator)
968
969
add_increment(stream_record)
970
break
0 commit comments