Fix lint on b/452032333

Author: KasiaStrz

samples/snippets/writes/noxfile.py

@@ -160,6 +160,7 @@ def blacken(session: nox.sessions.Session) -> None:
 # format = isort + black
 #
 
+
 @nox.session
 def format(session: nox.sessions.Session) -> None:
     """
@@ -187,7 +188,9 @@ def _session_tests(
     session: nox.sessions.Session, post_install: Callable = None
 ) -> None:
     # check for presence of tests
-    test_list = glob.glob("**/*_test.py", recursive=True) + glob.glob("**/test_*.py", recursive=True)
+    test_list = glob.glob("**/*_test.py", recursive=True) + glob.glob(
+        "**/test_*.py", recursive=True
+    )
     test_list.extend(glob.glob("**/tests", recursive=True))
 
     if len(test_list) == 0:
@@ -209,9 +212,7 @@ def _session_tests(
 
     if os.path.exists("requirements-test.txt"):
         if os.path.exists("constraints-test.txt"):
-            session.install(
-                "-r", "requirements-test.txt", "-c", "constraints-test.txt"
-            )
+            session.install("-r", "requirements-test.txt", "-c", "constraints-test.txt")
         else:
             session.install("-r", "requirements-test.txt")
         with open("requirements-test.txt") as rtfile:
@@ -224,9 +225,9 @@ def _session_tests(
         post_install(session)
 
     if "pytest-parallel" in packages:
-        concurrent_args.extend(['--workers', 'auto', '--tests-per-worker', 'auto'])
+        concurrent_args.extend(["--workers", "auto", "--tests-per-worker", "auto"])
     elif "pytest-xdist" in packages:
-        concurrent_args.extend(['-n', 'auto'])
+        concurrent_args.extend(["-n", "auto"])
 
     session.run(
         "pytest",
@@ -256,7 +257,7 @@ def py(session: nox.sessions.Session) -> None:
 
 
 def _get_repo_root() -> Optional[str]:
-    """ Returns the root folder of the project. """
+    """Returns the root folder of the project."""
     # Get root of this repository. Assume we don't have directories nested deeper than 10 items.
     p = Path(os.getcwd())
     for i in range(10):

samples/snippets/writes/write_increment_async.py

@@ -3,6 +3,7 @@
 from google.cloud.bigtable.data.mutations import AddToCell, RowMutationEntry
 from google.cloud.bigtable.data.exceptions import MutationsExceptionGroup
 
+
 async def write_increment_async(project_id, instance_id, table_id):
     """Increments a value in a Bigtable table using the async client."""
     async with BigtableDataClientAsync(project=project_id) as client:
@@ -13,11 +14,11 @@ async def write_increment_async(project_id, instance_id, table_id):
                 # The AddToCell mutation increments the value of a cell.
                 # The value must be a positive or negative integer.
                 reading = AddToCell(
-                    family="counters",
-                    qualifier="odometer",
-                    value=32304
+                    family="counters", qualifier="odometer", value=32304
+                )
+                await batcher.append(
+                    RowMutationEntry(row_key.encode("utf-8"), [reading])
                 )
-                await batcher.append(RowMutationEntry(row_key.encode("utf-8"), [reading]))
         except MutationsExceptionGroup as e:
             # MutationsExceptionGroup contains a FailedMutationEntryError for
             # each mutation that failed.
@@ -27,4 +28,6 @@ async def write_increment_async(project_id, instance_id, table_id):
                 print(
                     f"Failed mutation for row {failed_entry.row_key!r} with error: {cause!r}"
                 )
+
+
 # [END bigtable_write_increment_async]

samples/snippets/writes/writes_test.py

@@ -80,4 +80,4 @@ def _write_increment_async():
 
     _write_increment_async()
     out, _ = capsys.readouterr()
-    assert "Successfully incremented row" in out
+    assert "Successfully incremented row" in out