Skip to content

Commit 830d600

Browse files
partheaparthea
authored
chore: move version to gapic_version.py (#830)
1 parent 34c0540 commit 830d600

17 files changed

Lines changed: 179 additions & 5152 deletions

File tree

‎packages/google-cloud-pubsub/.github/CODEOWNERS‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3,10 +3,10 @@
33
#
44
# For syntax help see:
55
# https://help.github.com/en/github/creating-cloning-and-archiving-repositories/about-code-owners#codeowners-syntax
6+
# Note: This file is autogenerated. To make changes to the codeowner team, please update .repo-metadata.json.
67

8+
# @googleapis/yoshi-python @googleapis/api-pubsub are the default owners for changes in this repo
9+
* @googleapis/yoshi-python @googleapis/api-pubsub
710

8-
# The @googleapis/api-pubsub and yoshi-python are the default owners for changes in this repo
9-
* @googleapis/api-pubsub @googleapis/yoshi-python
10-
11-
# Additionally, the python-samples-reviewers team is also among the default owners for samples changes
12-
/samples/ @googleapis/api-pubsub @googleapis/python-samples-owners @googleapis/yoshi-python
11+
# @googleapis/python-samples-reviewers @googleapis/api-pubsub are the default owners for samples changes
12+
/samples/ @googleapis/python-samples-reviewers @googleapis/api-pubsub

‎packages/google-cloud-pubsub/.github/release-please.yml‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
releaseType: python
22
handleGHRelease: true
3+
manifest: true
34
# NOTE: this section is generated by synthtool.languages.python
45
# See https://github.com/googleapis/synthtool/blob/master/synthtool/languages/python.py
56
branches:

‎packages/google-cloud-pubsub/.release-please-manifest.json‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
{
2+
".": "2.13.11"
3+
}
4+

‎packages/google-cloud-pubsub/google/pubsub/gapic_version.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,4 +13,4 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16-
__version__ = "0.1.0"
16+
__version__ = "2.13.11" # {x-release-please-version}

‎packages/google-cloud-pubsub/google/pubsub_v1/services/publisher/async_client.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,7 @@ async def create_topic(
223223
*,
224224
name: Optional[str] = None,
225225
retry: OptionalRetry = gapic_v1.method.DEFAULT,
226-
timeout: Optional[float] = None,
226+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
227227
metadata: Sequence[Tuple[str, str]] = (),
228228
) -> pubsub.Topic:
229229
r"""Creates the given topic with the given name. See the [resource
@@ -339,7 +339,7 @@ async def update_topic(
339339
request: Optional[Union[pubsub.UpdateTopicRequest, dict]] = None,
340340
*,
341341
retry: OptionalRetry = gapic_v1.method.DEFAULT,
342-
timeout: Optional[float] = None,
342+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
343343
metadata: Sequence[Tuple[str, str]] = (),
344344
) -> pubsub.Topic:
345345
r"""Updates an existing topic. Note that certain
@@ -434,7 +434,7 @@ async def publish(
434434
topic: Optional[str] = None,
435435
messages: Optional[MutableSequence[pubsub.PubsubMessage]] = None,
436436
retry: OptionalRetry = gapic_v1.method.DEFAULT,
437-
timeout: Optional[float] = None,
437+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
438438
metadata: Sequence[Tuple[str, str]] = (),
439439
) -> pubsub.PublishResponse:
440440
r"""Adds one or more messages to the topic. Returns ``NOT_FOUND`` if
@@ -558,7 +558,7 @@ async def get_topic(
558558
*,
559559
topic: Optional[str] = None,
560560
retry: OptionalRetry = gapic_v1.method.DEFAULT,
561-
timeout: Optional[float] = None,
561+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
562562
metadata: Sequence[Tuple[str, str]] = (),
563563
) -> pubsub.Topic:
564564
r"""Gets the configuration of a topic.
@@ -669,7 +669,7 @@ async def list_topics(
669669
*,
670670
project: Optional[str] = None,
671671
retry: OptionalRetry = gapic_v1.method.DEFAULT,
672-
timeout: Optional[float] = None,
672+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
673673
metadata: Sequence[Tuple[str, str]] = (),
674674
) -> pagers.ListTopicsAsyncPager:
675675
r"""Lists matching topics.
@@ -794,7 +794,7 @@ async def list_topic_subscriptions(
794794
*,
795795
topic: Optional[str] = None,
796796
retry: OptionalRetry = gapic_v1.method.DEFAULT,
797-
timeout: Optional[float] = None,
797+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
798798
metadata: Sequence[Tuple[str, str]] = (),
799799
) -> pagers.ListTopicSubscriptionsAsyncPager:
800800
r"""Lists the names of the attached subscriptions on this
@@ -922,7 +922,7 @@ async def list_topic_snapshots(
922922
*,
923923
topic: Optional[str] = None,
924924
retry: OptionalRetry = gapic_v1.method.DEFAULT,
925-
timeout: Optional[float] = None,
925+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
926926
metadata: Sequence[Tuple[str, str]] = (),
927927
) -> pagers.ListTopicSnapshotsAsyncPager:
928928
r"""Lists the names of the snapshots on this topic. Snapshots are
@@ -1054,7 +1054,7 @@ async def delete_topic(
10541054
*,
10551055
topic: Optional[str] = None,
10561056
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1057-
timeout: Optional[float] = None,
1057+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
10581058
metadata: Sequence[Tuple[str, str]] = (),
10591059
) -> None:
10601060
r"""Deletes the topic with the given name. Returns ``NOT_FOUND`` if
@@ -1158,7 +1158,7 @@ async def detach_subscription(
11581158
request: Optional[Union[pubsub.DetachSubscriptionRequest, dict]] = None,
11591159
*,
11601160
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1161-
timeout: Optional[float] = None,
1161+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
11621162
metadata: Sequence[Tuple[str, str]] = (),
11631163
) -> pubsub.DetachSubscriptionResponse:
11641164
r"""Detaches a subscription from this topic. All messages retained
@@ -1254,7 +1254,7 @@ async def set_iam_policy(
12541254
request: Optional[iam_policy_pb2.SetIamPolicyRequest] = None,
12551255
*,
12561256
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1257-
timeout: Optional[float] = None,
1257+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
12581258
metadata: Sequence[Tuple[str, str]] = (),
12591259
) -> policy_pb2.Policy:
12601260
r"""Sets the IAM access control policy on the specified function.
@@ -1374,7 +1374,7 @@ async def get_iam_policy(
13741374
request: Optional[iam_policy_pb2.GetIamPolicyRequest] = None,
13751375
*,
13761376
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1377-
timeout: Optional[float] = None,
1377+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
13781378
metadata: Sequence[Tuple[str, str]] = (),
13791379
) -> policy_pb2.Policy:
13801380
r"""Gets the IAM access control policy for a function.
@@ -1496,7 +1496,7 @@ async def test_iam_permissions(
14961496
request: Optional[iam_policy_pb2.TestIamPermissionsRequest] = None,
14971497
*,
14981498
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1499-
timeout: Optional[float] = None,
1499+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
15001500
metadata: Sequence[Tuple[str, str]] = (),
15011501
) -> iam_policy_pb2.TestIamPermissionsResponse:
15021502
r"""Tests the specified permissions against the IAM access control

‎packages/google-cloud-pubsub/google/pubsub_v1/services/publisher/client.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -503,7 +503,7 @@ def create_topic(
503503
*,
504504
name: Optional[str] = None,
505505
retry: OptionalRetry = gapic_v1.method.DEFAULT,
506-
timeout: Optional[float] = None,
506+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
507507
metadata: Sequence[Tuple[str, str]] = (),
508508
) -> pubsub.Topic:
509509
r"""Creates the given topic with the given name. See the [resource
@@ -610,7 +610,7 @@ def update_topic(
610610
request: Optional[Union[pubsub.UpdateTopicRequest, dict]] = None,
611611
*,
612612
retry: OptionalRetry = gapic_v1.method.DEFAULT,
613-
timeout: Optional[float] = None,
613+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
614614
metadata: Sequence[Tuple[str, str]] = (),
615615
) -> pubsub.Topic:
616616
r"""Updates an existing topic. Note that certain
@@ -697,7 +697,7 @@ def publish(
697697
topic: Optional[str] = None,
698698
messages: Optional[MutableSequence[pubsub.PubsubMessage]] = None,
699699
retry: OptionalRetry = gapic_v1.method.DEFAULT,
700-
timeout: Optional[float] = None,
700+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
701701
metadata: Sequence[Tuple[str, str]] = (),
702702
) -> pubsub.PublishResponse:
703703
r"""Adds one or more messages to the topic. Returns ``NOT_FOUND`` if
@@ -806,7 +806,7 @@ def get_topic(
806806
*,
807807
topic: Optional[str] = None,
808808
retry: OptionalRetry = gapic_v1.method.DEFAULT,
809-
timeout: Optional[float] = None,
809+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
810810
metadata: Sequence[Tuple[str, str]] = (),
811811
) -> pubsub.Topic:
812812
r"""Gets the configuration of a topic.
@@ -906,7 +906,7 @@ def list_topics(
906906
*,
907907
project: Optional[str] = None,
908908
retry: OptionalRetry = gapic_v1.method.DEFAULT,
909-
timeout: Optional[float] = None,
909+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
910910
metadata: Sequence[Tuple[str, str]] = (),
911911
) -> pagers.ListTopicsPager:
912912
r"""Lists matching topics.
@@ -1020,7 +1020,7 @@ def list_topic_subscriptions(
10201020
*,
10211021
topic: Optional[str] = None,
10221022
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1023-
timeout: Optional[float] = None,
1023+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
10241024
metadata: Sequence[Tuple[str, str]] = (),
10251025
) -> pagers.ListTopicSubscriptionsPager:
10261026
r"""Lists the names of the attached subscriptions on this
@@ -1137,7 +1137,7 @@ def list_topic_snapshots(
11371137
*,
11381138
topic: Optional[str] = None,
11391139
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1140-
timeout: Optional[float] = None,
1140+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
11411141
metadata: Sequence[Tuple[str, str]] = (),
11421142
) -> pagers.ListTopicSnapshotsPager:
11431143
r"""Lists the names of the snapshots on this topic. Snapshots are
@@ -1258,7 +1258,7 @@ def delete_topic(
12581258
*,
12591259
topic: Optional[str] = None,
12601260
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1261-
timeout: Optional[float] = None,
1261+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
12621262
metadata: Sequence[Tuple[str, str]] = (),
12631263
) -> None:
12641264
r"""Deletes the topic with the given name. Returns ``NOT_FOUND`` if
@@ -1353,7 +1353,7 @@ def detach_subscription(
13531353
request: Optional[Union[pubsub.DetachSubscriptionRequest, dict]] = None,
13541354
*,
13551355
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1356-
timeout: Optional[float] = None,
1356+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
13571357
metadata: Sequence[Tuple[str, str]] = (),
13581358
) -> pubsub.DetachSubscriptionResponse:
13591359
r"""Detaches a subscription from this topic. All messages retained
@@ -1454,7 +1454,7 @@ def set_iam_policy(
14541454
request: Optional[iam_policy_pb2.SetIamPolicyRequest] = None,
14551455
*,
14561456
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1457-
timeout: Optional[float] = None,
1457+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
14581458
metadata: Sequence[Tuple[str, str]] = (),
14591459
) -> policy_pb2.Policy:
14601460
r"""Sets the IAM access control policy on the specified function.
@@ -1575,7 +1575,7 @@ def get_iam_policy(
15751575
request: Optional[iam_policy_pb2.GetIamPolicyRequest] = None,
15761576
*,
15771577
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1578-
timeout: Optional[float] = None,
1578+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
15791579
metadata: Sequence[Tuple[str, str]] = (),
15801580
) -> policy_pb2.Policy:
15811581
r"""Gets the IAM access control policy for a function.
@@ -1697,7 +1697,7 @@ def test_iam_permissions(
16971697
request: Optional[iam_policy_pb2.TestIamPermissionsRequest] = None,
16981698
*,
16991699
retry: OptionalRetry = gapic_v1.method.DEFAULT,
1700-
timeout: Optional[float] = None,
1700+
timeout: TimeoutType = gapic_v1.method.DEFAULT,
17011701
metadata: Sequence[Tuple[str, str]] = (),
17021702
) -> iam_policy_pb2.TestIamPermissionsResponse:
17031703
r"""Tests the specified IAM permissions against the IAM access control

0 commit comments

Comments
 (0)