From 89590df8bf808b866056bef1611719a0058be821 Mon Sep 17 00:00:00 2001 From: Owl Bot Date: Thu, 14 Mar 2024 21:03:03 +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 | 7 ++++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/samples/snippets/publisher.py b/samples/snippets/publisher.py index 2ecbfd2f0..1f40f764b 100644 --- a/samples/snippets/publisher.py +++ b/samples/snippets/publisher.py @@ -145,8 +145,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) @@ -535,7 +534,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 e29dec65d..ac91ddb81 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,7 +194,7 @@ 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