Make sure tasks are always added

Author: Cito

src/graphql/execution/execute.py

@@ -1504,7 +1504,7 @@ async def await_data() -> None:
                             incremental_data_record, data
                         )
 
-                self.add_task(await_data())  # type: ignore
+                self.add_task(await_data())
 
             else:
                 incremental_publisher.complete_deferred_fragment_record(
@@ -1562,7 +1562,7 @@ async def await_completed_awaitable_item() -> None:
                         incremental_data_record, [value]
                     )
 
-            self.add_task(await_completed_awaitable_item())  # type: ignore
+            self.add_task(await_completed_awaitable_item())
             return incremental_data_record
 
         try:
@@ -1622,6 +1622,7 @@ async def await_completed_item() -> None:
                         incremental_data_record, [value]
                     )
 
+            self.add_task(await_completed_item())
             return incremental_data_record
 
         incremental_publisher.complete_stream_items_record(

src/graphql/execution/incremental_publisher.py

@@ -497,7 +497,7 @@ def filter(
                     except AttributeError:
                         pass
                     else:
-                        self._add_task(close_async_iterator)  # type: ignore
+                        self._add_task(close_async_iterator)
 
     def _trigger(self) -> None:
         self._resolve.set()