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 258cc64 commit 81ef8aaCopy full SHA for 81ef8aa
src/graphql/execution/incremental_graph.py
@@ -164,8 +164,6 @@ def _remove_root_node(
164
) -> None:
165
"""Remove root node."""
166
del self._root_nodes[subsequent_result_record]
167
- if not self._root_nodes:
168
- self.stop_incremental_data()
169
170
def _add_incremental_data_records(
171
self,
@@ -337,6 +335,8 @@ def _yield_current_completed_incremental_data(
337
335
queue = self._completed_queue
338
336
while queue:
339
yield queue.pop(0)
+ if not self._root_nodes:
+ self.stop_incremental_data()
340
341
def _enqueue(self, completed: IncrementalDataRecordResult) -> None:
342
"""Enqueue completed incremental data record result."""
0 commit comments