removed duplicated types from docstrings

google/cloud/bigtable/data/execute_query/_async/execute_query_iterator.py

@@ -59,18 +59,18 @@ class ExecuteQueryIteratorAsync:
     It is **not thread-safe**. It should not be used by multiple asyncio Tasks.
 
     Args:
-        client (google.cloud.bigtable.data.BigtableDataClientAsync): bigtable client
-        instance_id (str): id of the instance on which the query is executed
-        request_body (Dict[str, Any]): dict representing the body of the ExecuteQueryRequest
-        attempt_timeout (float | None): the time budget for the entire operation, in seconds.
+        client: bigtable client
+        instance_id: id of the instance on which the query is executed
+        request_body: dict representing the body of the ExecuteQueryRequest
+        attempt_timeout: the time budget for the entire operation, in seconds.
             Failed requests will be retried within the budget.
             Defaults to 600 seconds.
-        operation_timeout (float): the time budget for an individual network request, in seconds.
+        operation_timeout: the time budget for an individual network request, in seconds.
             If it takes longer than this time to complete, the request will be cancelled with
             a DeadlineExceeded exception, and a retry will be attempted.
             Defaults to the 20 seconds. If None, defaults to operation_timeout.
-        req_metadata (Sequence[Tuple[str, str]]): metadata used while sending the gRPC request
-        retryable_excs (List[type[Exception]]): a list of errors that will be retried if encountered.
+        req_metadata: metadata used while sending the gRPC request
+        retryable_excs: a list of errors that will be retried if encountered.
     Raises:
         RuntimeError: if the instance is not created within an async event loop context.
     """
@@ -185,7 +185,7 @@ async def _next_impl(self) -> AsyncIterator[QueryResultRow]:
                 yield result
         await self.close()
 
-    async def __anext__(self):
+    async def __anext__(self) -> QueryResultRow:
         if self._is_closed:
             raise StopAsyncIteration
         return await self._result_generator.__anext__()