🦉 Updates from OwlBot post-processor

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

google/pubsub_v1/services/publisher/async_client.py

@@ -345,7 +345,8 @@ async def update_topic(
         timeout: TimeoutType = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pubsub.Topic:
-        r"""Updates an existing topic. Note that certain
+        r"""Updates an existing topic by updating the fields
+        specified in the update mask. Note that certain
         properties of a topic are not modifiable.
 
         .. code-block:: python
@@ -555,7 +556,7 @@ async def sample_publish():
             default_retry=retries.AsyncRetry(
                 initial=0.1,
                 maximum=60.0,
-                multiplier=4.0,
+                multiplier=4,
                 predicate=retries.if_exception_type(
                     core_exceptions.Aborted,
                     core_exceptions.Cancelled,

google/pubsub_v1/services/publisher/client.py

@@ -619,7 +619,8 @@ def update_topic(
         timeout: TimeoutType = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pubsub.Topic:
-        r"""Updates an existing topic. Note that certain
+        r"""Updates an existing topic by updating the fields
+        specified in the update mask. Note that certain
         properties of a topic are not modifiable.
 
         .. code-block:: python

google/pubsub_v1/services/publisher/transports/base.py

@@ -162,7 +162,7 @@ def _prep_wrapped_messages(self, client_info):
                 default_retry=retries.Retry(
                     initial=0.1,
                     maximum=60.0,
-                    multiplier=4.0,
+                    multiplier=4,
                     predicate=retries.if_exception_type(
                         core_exceptions.Aborted,
                         core_exceptions.Cancelled,

google/pubsub_v1/services/publisher/transports/grpc.py

@@ -265,7 +265,8 @@ def create_topic(self) -> Callable[[pubsub.Topic], pubsub.Topic]:
     def update_topic(self) -> Callable[[pubsub.UpdateTopicRequest], pubsub.Topic]:
         r"""Return a callable for the update topic method over gRPC.
 
-        Updates an existing topic. Note that certain
+        Updates an existing topic by updating the fields
+        specified in the update mask. Note that certain
         properties of a topic are not modifiable.
 
         Returns:

google/pubsub_v1/services/publisher/transports/grpc_asyncio.py

@@ -270,7 +270,8 @@ def update_topic(
     ) -> Callable[[pubsub.UpdateTopicRequest], Awaitable[pubsub.Topic]]:
         r"""Return a callable for the update topic method over gRPC.
 
-        Updates an existing topic. Note that certain
+        Updates an existing topic by updating the fields
+        specified in the update mask. Note that certain
         properties of a topic are not modifiable.
 
         Returns:

google/pubsub_v1/services/schema_service/async_client.py

@@ -285,7 +285,7 @@ async def sample_create_schema():
                 final component of the schema's resource name.
 
                 See
-                https://cloud.google.com/pubsub/docs/admin#resource_names
+                https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names
                 for resource name constraints.
 
                 This corresponds to the ``schema_id`` field

google/pubsub_v1/services/schema_service/client.py

@@ -519,7 +519,7 @@ def sample_create_schema():
                 final component of the schema's resource name.
 
                 See
-                https://cloud.google.com/pubsub/docs/admin#resource_names
+                https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names
                 for resource name constraints.
 
                 This corresponds to the ``schema_id`` field

google/pubsub_v1/services/subscriber/async_client.py

@@ -308,21 +308,21 @@ async def sample_create_subscription():
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
             push_config (:class:`google.pubsub_v1.types.PushConfig`):
-                If push delivery is used with this
-                subscription, this field is used to
-                configure it.
+                Optional. If push delivery is used
+                with this subscription, this field is
+                used to configure it.
 
                 This corresponds to the ``push_config`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
             ack_deadline_seconds (:class:`int`):
-                The approximate amount of time (on a best-effort basis)
-                Pub/Sub waits for the subscriber to acknowledge receipt
-                before resending the message. In the interval after the
-                message is delivered and before it is acknowledged, it
-                is considered to be *outstanding*. During that time
-                period, the message will not be redelivered (on a
-                best-effort basis).
+                Optional. The approximate amount of time (on a
+                best-effort basis) Pub/Sub waits for the subscriber to
+                acknowledge receipt before resending the message. In the
+                interval after the message is delivered and before it is
+                acknowledged, it is considered to be *outstanding*.
+                During that time period, the message will not be
+                redelivered (on a best-effort basis).
 
                 For pull subscriptions, this value is used as the
                 initial value for the ack deadline. To override this
@@ -544,7 +544,8 @@ async def update_subscription(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pubsub.Subscription:
-        r"""Updates an existing subscription. Note that certain
+        r"""Updates an existing subscription by updating the
+        fields specified in the update mask. Note that certain
         properties of a subscription, such as its topic, are not
         modifiable.
 
@@ -965,8 +966,8 @@ async def sample_modify_ack_deadline():
                 client. This typically results in an increase in the
                 rate of message redeliveries (that is, duplicates). The
                 minimum deadline you can specify is 0 seconds. The
-                maximum deadline you can specify is 600 seconds (10
-                minutes).
+                maximum deadline you can specify in a single request is
+                600 seconds (10 minutes).
 
                 This corresponds to the ``ack_deadline_seconds`` field
                 on the ``request`` instance; if ``request`` is provided, this
@@ -1383,7 +1384,7 @@ def request_generator():
             default_retry=retries.AsyncRetry(
                 initial=0.1,
                 maximum=60.0,
-                multiplier=4.0,
+                multiplier=4,
                 predicate=retries.if_exception_type(
                     core_exceptions.Aborted,
                     core_exceptions.DeadlineExceeded,
@@ -1946,7 +1947,8 @@ async def update_snapshot(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pubsub.Snapshot:
-        r"""Updates an existing snapshot. Snapshots are used in
+        r"""Updates an existing snapshot by updating the fields specified in
+        the update mask. Snapshots are used in
         `Seek <https://cloud.google.com/pubsub/docs/replay-overview>`__
         operations, which allow you to manage message acknowledgments in
         bulk. That is, you can set the acknowledgment state of messages

google/pubsub_v1/services/subscriber/client.py

@@ -589,21 +589,21 @@ def sample_create_subscription():
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
             push_config (google.pubsub_v1.types.PushConfig):
-                If push delivery is used with this
-                subscription, this field is used to
-                configure it.
+                Optional. If push delivery is used
+                with this subscription, this field is
+                used to configure it.
 
                 This corresponds to the ``push_config`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
             ack_deadline_seconds (int):
-                The approximate amount of time (on a best-effort basis)
-                Pub/Sub waits for the subscriber to acknowledge receipt
-                before resending the message. In the interval after the
-                message is delivered and before it is acknowledged, it
-                is considered to be *outstanding*. During that time
-                period, the message will not be redelivered (on a
-                best-effort basis).
+                Optional. The approximate amount of time (on a
+                best-effort basis) Pub/Sub waits for the subscriber to
+                acknowledge receipt before resending the message. In the
+                interval after the message is delivered and before it is
+                acknowledged, it is considered to be *outstanding*.
+                During that time period, the message will not be
+                redelivered (on a best-effort basis).
 
                 For pull subscriptions, this value is used as the
                 initial value for the ack deadline. To override this
@@ -803,7 +803,8 @@ def update_subscription(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pubsub.Subscription:
-        r"""Updates an existing subscription. Note that certain
+        r"""Updates an existing subscription by updating the
+        fields specified in the update mask. Note that certain
         properties of a subscription, such as its topic, are not
         modifiable.
 
@@ -1195,8 +1196,8 @@ def sample_modify_ack_deadline():
                 client. This typically results in an increase in the
                 rate of message redeliveries (that is, duplicates). The
                 minimum deadline you can specify is 0 seconds. The
-                maximum deadline you can specify is 600 seconds (10
-                minutes).
+                maximum deadline you can specify in a single request is
+                600 seconds (10 minutes).
 
                 This corresponds to the ``ack_deadline_seconds`` field
                 on the ``request`` instance; if ``request`` is provided, this
@@ -2094,7 +2095,8 @@ def update_snapshot(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pubsub.Snapshot:
-        r"""Updates an existing snapshot. Snapshots are used in
+        r"""Updates an existing snapshot by updating the fields specified in
+        the update mask. Snapshots are used in
         `Seek <https://cloud.google.com/pubsub/docs/replay-overview>`__
         operations, which allow you to manage message acknowledgments in
         bulk. That is, you can set the acknowledgment state of messages

google/pubsub_v1/services/subscriber/transports/base.py

@@ -255,7 +255,7 @@ def _prep_wrapped_messages(self, client_info):
                 default_retry=retries.Retry(
                     initial=0.1,
                     maximum=60.0,
-                    multiplier=4.0,
+                    multiplier=4,
                     predicate=retries.if_exception_type(
                         core_exceptions.Aborted,
                         core_exceptions.DeadlineExceeded,

google/pubsub_v1/services/subscriber/transports/grpc.py

@@ -307,7 +307,8 @@ def update_subscription(
     ) -> Callable[[pubsub.UpdateSubscriptionRequest], pubsub.Subscription]:
         r"""Return a callable for the update subscription method over gRPC.
 
-        Updates an existing subscription. Note that certain
+        Updates an existing subscription by updating the
+        fields specified in the update mask. Note that certain
         properties of a subscription, such as its topic, are not
         modifiable.
 
@@ -646,7 +647,8 @@ def update_snapshot(
     ) -> Callable[[pubsub.UpdateSnapshotRequest], pubsub.Snapshot]:
         r"""Return a callable for the update snapshot method over gRPC.
 
-        Updates an existing snapshot. Snapshots are used in
+        Updates an existing snapshot by updating the fields specified in
+        the update mask. Snapshots are used in
         `Seek <https://cloud.google.com/pubsub/docs/replay-overview>`__
         operations, which allow you to manage message acknowledgments in
         bulk. That is, you can set the acknowledgment state of messages

google/pubsub_v1/services/subscriber/transports/grpc_asyncio.py

@@ -310,7 +310,8 @@ def update_subscription(
     ) -> Callable[[pubsub.UpdateSubscriptionRequest], Awaitable[pubsub.Subscription]]:
         r"""Return a callable for the update subscription method over gRPC.
 
-        Updates an existing subscription. Note that certain
+        Updates an existing subscription by updating the
+        fields specified in the update mask. Note that certain
         properties of a subscription, such as its topic, are not
         modifiable.
 
@@ -659,7 +660,8 @@ def update_snapshot(
     ) -> Callable[[pubsub.UpdateSnapshotRequest], Awaitable[pubsub.Snapshot]]:
         r"""Return a callable for the update snapshot method over gRPC.
 
-        Updates an existing snapshot. Snapshots are used in
+        Updates an existing snapshot by updating the fields specified in
+        the update mask. Snapshots are used in
         `Seek <https://cloud.google.com/pubsub/docs/replay-overview>`__
         operations, which allow you to manage message acknowledgments in
         bulk. That is, you can set the acknowledgment state of messages