diff --git a/samples/snippets/data_client/data_client_snippets_async.py b/samples/snippets/data_client/data_client_snippets_async.py
index cb51bdc78..742e7cb8e 100644
--- a/samples/snippets/data_client/data_client_snippets_async.py
+++ b/samples/snippets/data_client/data_client_snippets_async.py
@@ -42,24 +42,34 @@ async def write_batch(table):
     from google.cloud.bigtable.data import BigtableDataClientAsync
     from google.cloud.bigtable.data.mutations import SetCell
     from google.cloud.bigtable.data.mutations import RowMutationEntry
+    from google.cloud.bigtable.data.exceptions import MutationsExceptionGroup
 
     async def write_batch(project_id, instance_id, table_id):
         async with BigtableDataClientAsync(project=project_id) as client:
             async with client.get_table(instance_id, table_id) as table:
                 family_id = "stats_summary"
-
-                async with table.mutations_batcher() as batcher:
-                    mutation_list = [
-                        SetCell(family_id, "connected_cell", 1),
-                        SetCell(family_id, "connected_wifi", 1),
-                        SetCell(family_id, "os_build", "12155.0.0-rc1"),
-                    ]
-                    batcher.append(
-                        RowMutationEntry("tablet#a0b81f74#20190501", mutation_list)
-                    )
-                    batcher.append(
-                        RowMutationEntry("tablet#a0b81f74#20190502", mutation_list)
-                    )
+                try:
+                    async with table.mutations_batcher() as batcher:
+                        mutation_list = [
+                            SetCell(family_id, "connected_cell", 1),
+                            SetCell(family_id, "connected_wifi", 1),
+                            SetCell(family_id, "os_build", "12155.0.0-rc1"),
+                        ]
+                        # awaiting the batcher.append method adds the RowMutationEntry
+                        # to the batcher's queue to be written in the next flush.
+                        await batcher.append(
+                            RowMutationEntry("tablet#a0b81f74#20190501", mutation_list)
+                        )
+                        await batcher.append(
+                            RowMutationEntry("tablet#a0b81f74#20190502", mutation_list)
+                        )
+                except MutationsExceptionGroup as e:
+                    # MutationsExceptionGroup contains a FailedMutationEntryError for
+                    # each mutation that failed.
+                    for sub_exception in e.exceptions:
+                        failed_entry: RowMutationEntry = sub_exception.entry
+                        cause: Exception = sub_exception.__cause__
+                        print(f"Failed mutation: {failed_entry.row_key} with error: {cause!r}")
     # [END bigtable_async_writes_batch]
     await write_batch(table.client.project, table.instance_id, table.table_id)