🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

samples/snippets/subscriber.py

@@ -581,10 +581,14 @@ def remove_dead_letter_policy(
     # [END pubsub_dead_letter_remove]
     return subscription_after_update
 
+
 def optimistic_subscribe(
-    project_id: str, topic_id: str, subscription_id: str, timeout: Optional[float] = None
+    project_id: str,
+    topic_id: str,
+    subscription_id: str,
+    timeout: Optional[float] = None,
 ) -> None:
-    """Optimistically subscribe to messages instead of making calls to verify existence 
+    """Optimistically subscribe to messages instead of making calls to verify existence
     of a subscription first and then subscribing to messages from it. This avoids admin
     operation calls to verify the existence of a subscription and reduces the probability
     of running out of quota for admin operations."""
@@ -612,12 +616,13 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None:
         # Ack message after processing it
         message.ack()
 
-
     # Wrap subscriber in a 'with' block to automatically call close() when done
     with subscriber:
         try:
             # Optimistically subscribe to messages on the subscription
-            streaming_pull_future = subscriber.subscribe(subscription_path, callback=callback)
+            streaming_pull_future = subscriber.subscribe(
+                subscription_path, callback=callback
+            )
             streaming_pull_future.result(timeout=timeout)
         except TimeoutError:
             streaming_pull_future.cancel()  # Trigger the shutdown.
@@ -629,10 +634,12 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None:
             subscription = subscriber.create_subscription(
                 request={"name": subscription_path, "topic": topic_path}
             )
-            
+
             # Subscribe on the created subscription
             try:
-                streaming_pull_future = subscriber.subscribe(subscription.name, callback=callback)
+                streaming_pull_future = subscriber.subscribe(
+                    subscription.name, callback=callback
+                )
                 streaming_pull_future.result(timeout=timeout)
             except TimeoutError:
                 streaming_pull_future.cancel()  # Trigger the shutdown.
@@ -1214,7 +1221,7 @@ def callback(message: pubsub_v1.subscriber.message.Message) -> None:
     )
     remove_dead_letter_policy_parser.add_argument("topic_id")
     remove_dead_letter_policy_parser.add_argument("subscription_id")
-   
+
     optimistic_subscribe_parser = subparsers.add_parser(
         "optimistic-subscribe", help=optimistic_subscribe.__doc__
     )