Skip to content
This repository was archived by the owner on Dec 31, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,13 @@

[1]: https://pypi.org/project/google-cloud-build/#history

### [2.0.1](https://github.com/googleapis/python-cloudbuild/compare/v2.0.0...v2.0.1) (2022-04-04)


### Bug Fixes

* **deps:** require google-api-core >= 1.31.5, >= 2.3.2 on v2 release ([#244](https://github.com/googleapis/python-cloudbuild/issues/244)) ([dd65eed](https://github.com/googleapis/python-cloudbuild/commit/dd65eedb062837a345f9e62eb85da1592921d3e9))

## [2.0.0](https://www.github.com/googleapis/python-cloudbuild/compare/v1.1.0...v2.0.0) (2020-07-23)


Expand Down
17 changes: 10 additions & 7 deletions docs/conf.py
Original file line number Diff line number Diff line change
Expand Up @@ -62,9 +62,9 @@
master_doc = "index"

# General information about the project.
project = u"google-cloud-build"
copyright = u"2019, Google"
author = u"Google APIs"
project = "google-cloud-build"
copyright = "2019, Google"
author = "Google APIs"

# The version info for the project you're documenting, acts as replacement for
# |version| and |release|, also used in various other places throughout the
Expand Down Expand Up @@ -258,7 +258,7 @@
(
master_doc,
"google-cloud-build.tex",
u"google-cloud-build Documentation",
"google-cloud-build Documentation",
author,
"manual",
)
Expand Down Expand Up @@ -293,7 +293,7 @@
(
master_doc,
"google-cloud-build",
u"google-cloud-build Documentation",
"google-cloud-build Documentation",
[author],
1,
)
Expand All @@ -312,7 +312,7 @@
(
master_doc,
"google-cloud-build",
u"google-cloud-build Documentation",
"google-cloud-build Documentation",
author,
"google-cloud-build",
"google-cloud-build Library",
Expand All @@ -337,7 +337,10 @@
intersphinx_mapping = {
"python": ("http://python.readthedocs.org/en/latest/", None),
"google-auth": ("https://google-auth.readthedocs.io/en/stable", None),
"google.api_core": ("https://googleapis.dev/python/google-api-core/latest/", None,),
"google.api_core": (
"https://googleapis.dev/python/google-api-core/latest/",
None,
),
"grpc": ("https://grpc.io/grpc/python/", None),
}

Expand Down
143 changes: 117 additions & 26 deletions google/cloud/devtools/cloudbuild_v1/services/cloud_build/async_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,9 @@ def __init__(
"""

self._client = CloudBuildClient(
credentials=credentials, transport=transport, client_options=client_options,
credentials=credentials,
transport=transport,
client_options=client_options,
)

async def create_build(
Expand Down Expand Up @@ -198,7 +200,12 @@ async def create_build(
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Wrap the response in an operation future.
response = operation_async.from_gapic(
Expand Down Expand Up @@ -301,15 +308,21 @@ async def get_build(
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
exceptions.ServiceUnavailable, exceptions.DeadlineExceeded,
exceptions.ServiceUnavailable,
exceptions.DeadlineExceeded,
),
),
default_timeout=600.0,
client_info=_client_info,
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Done; return the response.
return response
Expand Down Expand Up @@ -385,20 +398,29 @@ async def list_builds(
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
exceptions.ServiceUnavailable, exceptions.DeadlineExceeded,
exceptions.ServiceUnavailable,
exceptions.DeadlineExceeded,
),
),
default_timeout=600.0,
client_info=_client_info,
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# This method is paged; wrap the response in a pager, which provides
# an `__aiter__` convenience method.
response = pagers.ListBuildsAsyncPager(
method=rpc, request=request, response=response, metadata=metadata,
method=rpc,
request=request,
response=response,
metadata=metadata,
)

# Done; return the response.
Expand Down Expand Up @@ -490,7 +512,12 @@ async def cancel_build(
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Done; return the response.
return response
Expand Down Expand Up @@ -615,7 +642,12 @@ async def retry_build(
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Wrap the response in an operation future.
response = operation_async.from_gapic(
Expand Down Expand Up @@ -699,7 +731,12 @@ async def create_build_trigger(
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Done; return the response.
return response
Expand Down Expand Up @@ -776,15 +813,21 @@ async def get_build_trigger(
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
exceptions.ServiceUnavailable, exceptions.DeadlineExceeded,
exceptions.ServiceUnavailable,
exceptions.DeadlineExceeded,
),
),
default_timeout=600.0,
client_info=_client_info,
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Done; return the response.
return response
Expand Down Expand Up @@ -853,20 +896,29 @@ async def list_build_triggers(
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
exceptions.ServiceUnavailable, exceptions.DeadlineExceeded,
exceptions.ServiceUnavailable,
exceptions.DeadlineExceeded,
),
),
default_timeout=600.0,
client_info=_client_info,
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# This method is paged; wrap the response in a pager, which provides
# an `__aiter__` convenience method.
response = pagers.ListBuildTriggersAsyncPager(
method=rpc, request=request, response=response, metadata=metadata,
method=rpc,
request=request,
response=response,
metadata=metadata,
)

# Done; return the response.
Expand Down Expand Up @@ -935,7 +987,8 @@ async def delete_build_trigger(
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
exceptions.ServiceUnavailable, exceptions.DeadlineExceeded,
exceptions.ServiceUnavailable,
exceptions.DeadlineExceeded,
),
),
default_timeout=600.0,
Expand All @@ -944,7 +997,10 @@ async def delete_build_trigger(

# Send the request.
await rpc(
request, retry=retry, timeout=timeout, metadata=metadata,
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

async def update_build_trigger(
Expand Down Expand Up @@ -1026,7 +1082,12 @@ async def update_build_trigger(
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Done; return the response.
return response
Expand Down Expand Up @@ -1131,7 +1192,12 @@ async def run_build_trigger(
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Wrap the response in an operation future.
response = operation_async.from_gapic(
Expand Down Expand Up @@ -1197,7 +1263,12 @@ async def create_worker_pool(
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Done; return the response.
return response
Expand Down Expand Up @@ -1254,15 +1325,21 @@ async def get_worker_pool(
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
exceptions.ServiceUnavailable, exceptions.DeadlineExceeded,
exceptions.ServiceUnavailable,
exceptions.DeadlineExceeded,
),
),
default_timeout=600.0,
client_info=_client_info,
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Done; return the response.
return response
Expand Down Expand Up @@ -1303,7 +1380,10 @@ async def delete_worker_pool(

# Send the request.
await rpc(
request, retry=retry, timeout=timeout, metadata=metadata,
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

async def update_worker_pool(
Expand Down Expand Up @@ -1357,7 +1437,12 @@ async def update_worker_pool(
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Done; return the response.
return response
Expand Down Expand Up @@ -1401,15 +1486,21 @@ async def list_worker_pools(
maximum=60.0,
multiplier=1.3,
predicate=retries.if_exception_type(
exceptions.ServiceUnavailable, exceptions.DeadlineExceeded,
exceptions.ServiceUnavailable,
exceptions.DeadlineExceeded,
),
),
default_timeout=600.0,
client_info=_client_info,
)

# Send the request.
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
response = await rpc(
request,
retry=retry,
timeout=timeout,
metadata=metadata,
)

# Done; return the response.
return response
Expand Down
Loading