diff --git a/samples/snippets/subscriber.py b/samples/snippets/subscriber.py index 1bb60454d..ecb2cf17b 100644 --- a/samples/snippets/subscriber.py +++ b/samples/snippets/subscriber.py @@ -236,11 +236,7 @@ def create_subscription_with_filtering( with subscriber: subscription = subscriber.create_subscription( - request={ - "name": subscription_path, - "topic": topic_path, - "filter": filter, - } + request={"name": subscription_path, "topic": topic_path, "filter": filter} ) print(f"Created subscription with filtering enabled: {subscription}") # [END pubsub_create_subscription_with_filter] diff --git a/samples/snippets/subscriber_test.py b/samples/snippets/subscriber_test.py index 2699f698c..98d11967e 100644 --- a/samples/snippets/subscriber_test.py +++ b/samples/snippets/subscriber_test.py @@ -43,7 +43,7 @@ NEW_ENDPOINT = f"https://{PROJECT_ID}.appspot.com/push2" DEFAULT_MAX_DELIVERY_ATTEMPTS = 5 UPDATED_MAX_DELIVERY_ATTEMPTS = 20 -FILTER = "attributes.author=\"unknown\"" +FILTER = 'attributes.author="unknown"' C = TypeVar("C", bound=Callable[..., Any]) @@ -401,7 +401,9 @@ def test_create_subscription_with_filtering( except NotFound: pass - subscriber.create_subscription_with_filtering(PROJECT_ID, TOPIC, SUBSCRIPTION_ADMIN, FILTER) + subscriber.create_subscription_with_filtering( + PROJECT_ID, TOPIC, SUBSCRIPTION_ADMIN, FILTER + ) out, _ = capsys.readouterr() assert "Created subscription with filtering enabled" in out