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 faea5ad commit 2931653Copy full SHA for 2931653
src/graphql/execution/incremental_publisher.py
@@ -383,17 +383,21 @@ async def subscribe(
383
released = self._released
384
for item in released:
385
pending.discard(item)
386
-
387
self._released = (
388
set()
389
) # TODO, solve differently? use clear() and local variable?
+
390
result = self._get_incremental_result(released)
391
released.clear()
392
393
if not self.has_next():
394
is_done = True
395
396
if result is not None:
397
yield result
- await self._resolve.wait()
398
399
+ if not is_done:
400
+ await self._resolve.wait()
401
finally:
402
close_async_iterators = []
403
for incremental_data_record in pending:
0 commit comments