chore: move version to gapic_version.py (#830)

googleapis · Dec 2, 2022 · f3bf21d · f3bf21d
1 parent ce65d8a
commit f3bf21d
Show file tree

Hide file tree

Showing 17 changed files with 179 additions and 5,152 deletions.
diff --git a/.github/CODEOWNERS b/.github/CODEOWNERS
@@ -3,10 +3,10 @@
 #
 # For syntax help see:
 # https://help.github.com/en/github/creating-cloning-and-archiving-repositories/about-code-owners#codeowners-syntax
+# Note: This file is autogenerated. To make changes to the codeowner team, please update .repo-metadata.json.
 
+# @googleapis/yoshi-python @googleapis/api-pubsub are the default owners for changes in this repo
+* @googleapis/yoshi-python @googleapis/api-pubsub
 
-# The @googleapis/api-pubsub and yoshi-python are the default owners for changes in this repo
-* @googleapis/api-pubsub @googleapis/yoshi-python
-
-# Additionally, the python-samples-reviewers team is also among the default owners for samples changes
-/samples/ @googleapis/api-pubsub @googleapis/python-samples-owners @googleapis/yoshi-python
+# @googleapis/python-samples-reviewers @googleapis/api-pubsub are the default owners for samples changes
+/samples/ @googleapis/python-samples-reviewers @googleapis/api-pubsub
diff --git a/.github/release-please.yml b/.github/release-please.yml
@@ -1,5 +1,6 @@
 releaseType: python
 handleGHRelease: true
+manifest: true
 # NOTE: this section is generated by synthtool.languages.python
 # See https://github.com/googleapis/synthtool/blob/master/synthtool/languages/python.py
 branches:

diff --git a/.release-please-manifest.json b/.release-please-manifest.json
@@ -0,0 +1,4 @@
+{
+ ".": "2.13.11"
+}
+
diff --git a/google/pubsub/gapic_version.py b/google/pubsub/gapic_version.py
@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "0.1.0"
+__version__ = "2.13.11" # {x-release-please-version}
diff --git a/google/pubsub_v1/services/publisher/async_client.py b/google/pubsub_v1/services/publisher/async_client.py
@@ -223,7 +223,7 @@ async def create_topic(
  *,
  name: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.Topic:
  r"""Creates the given topic with the given name. See the [resource
@@ -339,7 +339,7 @@ async def update_topic(
  request: Optional[Union[pubsub.UpdateTopicRequest, dict]] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.Topic:
  r"""Updates an existing topic. Note that certain
@@ -434,7 +434,7 @@ async def publish(
  topic: Optional[str] = None,
  messages: Optional[MutableSequence[pubsub.PubsubMessage]] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.PublishResponse:
  r"""Adds one or more messages to the topic. Returns ``NOT_FOUND`` if
@@ -558,7 +558,7 @@ async def get_topic(
  *,
  topic: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.Topic:
  r"""Gets the configuration of a topic.
@@ -669,7 +669,7 @@ async def list_topics(
  *,
  project: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListTopicsAsyncPager:
  r"""Lists matching topics.
@@ -794,7 +794,7 @@ async def list_topic_subscriptions(
  *,
  topic: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListTopicSubscriptionsAsyncPager:
  r"""Lists the names of the attached subscriptions on this
@@ -922,7 +922,7 @@ async def list_topic_snapshots(
  *,
  topic: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListTopicSnapshotsAsyncPager:
  r"""Lists the names of the snapshots on this topic. Snapshots are
@@ -1054,7 +1054,7 @@ async def delete_topic(
  *,
  topic: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> None:
  r"""Deletes the topic with the given name. Returns ``NOT_FOUND`` if
@@ -1158,7 +1158,7 @@ async def detach_subscription(
  request: Optional[Union[pubsub.DetachSubscriptionRequest, dict]] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.DetachSubscriptionResponse:
  r"""Detaches a subscription from this topic. All messages retained
@@ -1254,7 +1254,7 @@ async def set_iam_policy(
  request: Optional[iam_policy_pb2.SetIamPolicyRequest] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> policy_pb2.Policy:
  r"""Sets the IAM access control policy on the specified function.
@@ -1374,7 +1374,7 @@ async def get_iam_policy(
  request: Optional[iam_policy_pb2.GetIamPolicyRequest] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> policy_pb2.Policy:
  r"""Gets the IAM access control policy for a function.
@@ -1496,7 +1496,7 @@ async def test_iam_permissions(
  request: Optional[iam_policy_pb2.TestIamPermissionsRequest] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> iam_policy_pb2.TestIamPermissionsResponse:
  r"""Tests the specified permissions against the IAM access control

diff --git a/google/pubsub_v1/services/publisher/client.py b/google/pubsub_v1/services/publisher/client.py
@@ -503,7 +503,7 @@ def create_topic(
  *,
  name: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.Topic:
  r"""Creates the given topic with the given name. See the [resource
@@ -610,7 +610,7 @@ def update_topic(
  request: Optional[Union[pubsub.UpdateTopicRequest, dict]] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.Topic:
  r"""Updates an existing topic. Note that certain
@@ -697,7 +697,7 @@ def publish(
  topic: Optional[str] = None,
  messages: Optional[MutableSequence[pubsub.PubsubMessage]] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.PublishResponse:
  r"""Adds one or more messages to the topic. Returns ``NOT_FOUND`` if
@@ -806,7 +806,7 @@ def get_topic(
  *,
  topic: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.Topic:
  r"""Gets the configuration of a topic.
@@ -906,7 +906,7 @@ def list_topics(
  *,
  project: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListTopicsPager:
  r"""Lists matching topics.
@@ -1020,7 +1020,7 @@ def list_topic_subscriptions(
  *,
  topic: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListTopicSubscriptionsPager:
  r"""Lists the names of the attached subscriptions on this
@@ -1137,7 +1137,7 @@ def list_topic_snapshots(
  *,
  topic: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListTopicSnapshotsPager:
  r"""Lists the names of the snapshots on this topic. Snapshots are
@@ -1258,7 +1258,7 @@ def delete_topic(
  *,
  topic: Optional[str] = None,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> None:
  r"""Deletes the topic with the given name. Returns ``NOT_FOUND`` if
@@ -1353,7 +1353,7 @@ def detach_subscription(
  request: Optional[Union[pubsub.DetachSubscriptionRequest, dict]] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pubsub.DetachSubscriptionResponse:
  r"""Detaches a subscription from this topic. All messages retained
@@ -1454,7 +1454,7 @@ def set_iam_policy(
  request: Optional[iam_policy_pb2.SetIamPolicyRequest] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> policy_pb2.Policy:
  r"""Sets the IAM access control policy on the specified function.
@@ -1575,7 +1575,7 @@ def get_iam_policy(
  request: Optional[iam_policy_pb2.GetIamPolicyRequest] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> policy_pb2.Policy:
  r"""Gets the IAM access control policy for a function.
@@ -1697,7 +1697,7 @@ def test_iam_permissions(
  request: Optional[iam_policy_pb2.TestIamPermissionsRequest] = None,
  *,
  retry: OptionalRetry = gapic_v1.method.DEFAULT,
- timeout: Optional[float] = None,
+ timeout: TimeoutType = gapic_v1.method.DEFAULT,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> iam_policy_pb2.TestIamPermissionsResponse:
  r"""Tests the specified IAM permissions against the IAM access control