address feedback

Author: parthea

packages/google-cloud-bigtable/tests/system/data/test_system_async.py

@@ -126,7 +126,11 @@ async def delete_rows(self):
                 # Await and consume the gRPC stream to guarantee execution
                 stream = await self.target.client._gapic_client.mutate_rows(request)
                 async for response in stream:
-                    pass
+                    for entry in response.entries:
+                        if entry.status.code != 0:
+                            raise RuntimeError(
+                                f"Failed to delete row: {entry.status.message}"
+                            )
 
     @CrossSync.convert
     async def retrieve_cell_value(self, target, row_key):

packages/google-cloud-bigtable/tests/system/data/test_system_autogen.py

@@ -107,7 +107,11 @@ def delete_rows(self):
                 }
                 stream = self.target.client._gapic_client.mutate_rows(request)
                 for response in stream:
-                    pass
+                    for entry in response.entries:
+                        if entry.status.code != 0:
+                            raise RuntimeError(
+                                f"Failed to delete row: {entry.status.message}"
+                            )
 
     def retrieve_cell_value(self, target, row_key):
         """Helper to read an individual row"""