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 f125b4e commit 645f154Copy full SHA for 645f154
src/graphql/execution/incremental_publisher.py
@@ -282,8 +282,9 @@ async def _handle_completed_stream_items(
282
"""Handle completed stream."""
283
stream_record = stream_items_result.stream_record
284
id_ = stream_record.id
285
- if id_ is None:
286
- return # pragma: no cover
+ if id_ is None: # pragma: no cover
+ msg = "Missing stream record identifier."
287
+ raise RuntimeError(msg)
288
incremental_graph = self._incremental_graph
289
if stream_items_result.errors is not None:
290
context.completed.append(CompletedResult(id_, stream_items_result.errors))
0 commit comments