lint

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]
@@ -771,7 +767,7 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None:
     # [END pubsub_dead_letter_delivery_attempt]
 
 
-if __name__ == "__main__":
+if __name__ == "__main__":  # noqa
     parser = argparse.ArgumentParser(
         description=__doc__, formatter_class=argparse.RawDescriptionHelpFormatter,
     )

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,12 +401,14 @@ 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
     assert f"{subscription_admin}" in out
-    assert f"filter: {FILTER}" in out
+    assert '"attributes.author=\\"unknown\\""' in out
 
 
 def test_create_push_subscription(