From 0974548575fee763095f1e478c478969a0843bbf Mon Sep 17 00:00:00 2001 From: Christoph Zwerschke Date: Sun, 7 Apr 2024 19:59:34 +0200 Subject: [PATCH] rename executeStreamIterator Replicates graphql/graphql-js@fab6426917e75d1b5b62543c12c81841ca99967d --- src/graphql/execution/execute.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/graphql/execution/execute.py b/src/graphql/execution/execute.py index 69f1c7ee..989a9d21 100644 --- a/src/graphql/execution/execute.py +++ b/src/graphql/execution/execute.py @@ -1242,7 +1242,7 @@ async def complete_async_iterator_value( with suppress(TimeoutError): await wait_for( shield( - self.execute_stream_iterator( + self.execute_stream_async_iterator( index, iterator, field_group, @@ -1859,7 +1859,7 @@ async def await_completed_items() -> list[Any] | None: async_payload_record.add_items(completed_items) return async_payload_record - async def execute_stream_iterator_item( + async def execute_stream_async_iterator_item( self, iterator: AsyncIterator[Any], field_group: FieldGroup, @@ -1893,7 +1893,7 @@ async def execute_stream_iterator_item( ) self.filter_subsequent_payloads(item_path, async_payload_record) - async def execute_stream_iterator( + async def execute_stream_async_iterator( self, initial_index: int, iterator: AsyncIterator[Any], @@ -1915,7 +1915,7 @@ async def execute_stream_iterator( ) try: - data = await self.execute_stream_iterator_item( + data = await self.execute_stream_async_iterator_item( iterator, field_group, info,