From 04cfb213077ae0cabfc0308f64a11bb85e17975e Mon Sep 17 00:00:00 2001
From: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
Date: Thu, 14 Mar 2024 22:33:54 +0000
Subject: [PATCH] =?UTF-8?q?=F0=9F=A6=89=20Updates=20from=20OwlBot=20post-p?=
 =?UTF-8?q?rocessor?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md
---
 samples/snippets/publisher.py      | 5 ++---
 samples/snippets/publisher_test.py | 9 +++++----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/samples/snippets/publisher.py b/samples/snippets/publisher.py
index 1b8c5e13e..6453762a3 100644
--- a/samples/snippets/publisher.py
+++ b/samples/snippets/publisher.py
@@ -142,8 +142,7 @@ def update_topic_kinesis_ingestion(
                 )
             ),
         ),
-        update_mask=field_mask_pb2.FieldMask(
-            paths=["ingestion_data_source_settings"]),
+        update_mask=field_mask_pb2.FieldMask(paths=["ingestion_data_source_settings"]),
     )
 
     topic = publisher.update_topic(request=update_request)
@@ -531,7 +530,7 @@ def detach_subscription(project_id: str, subscription_id: str) -> None:
     create_topic_kinesis_ingestion_parser.add_argument("consumer_arn")
     create_topic_kinesis_ingestion_parser.add_argument("aws_role_arn")
     create_topic_kinesis_ingestion_parser.add_argument("gcp_service_account")
-    
+
     update_topic_kinesis_ingestion_parser = subparsers.add_parser(
         "update_kinesis_ingestion", help=update_topic_kinesis_ingestion.__doc__
     )
diff --git a/samples/snippets/publisher_test.py b/samples/snippets/publisher_test.py
index e5939f9f6..1e673f134 100644
--- a/samples/snippets/publisher_test.py
+++ b/samples/snippets/publisher_test.py
@@ -160,7 +160,8 @@ def test_create_kinesis_ingestion(
 
     # Clean up resource created for the test.
     publisher_client.delete_topic(request={"topic": topic_path})
-    
+
+
 def test_update_kinesis_ingestion(
     publisher_client: pubsub_v1.PublisherClient, capsys: CaptureFixture[str]
 ) -> None:
@@ -184,7 +185,7 @@ def test_update_kinesis_ingestion(
 
     out, _ = capsys.readouterr()
     assert f"Created topic: {topic_path}" in out
-    
+
     publisher.update_topic_kinesis_ingestion(
         PROJECT_ID,
         TOPIC_ID,
@@ -193,10 +194,10 @@ def test_update_kinesis_ingestion(
         aws_role_arn,
         gcp_service_account,
     )
-    
+
     out, _ = capsys.readouterr()
     assert f"Updated topic: {topic_path} with AWS Kinesis Ingestion Settings" in out
-    
+
     # Clean up resource created for the test.
     publisher_client.delete_topic(request={"topic": topic_path})