Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 23e91f5

Browse filesBrowse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
fix: [google-cloud-tasks] remove BufferTask method which cannot be called from client libraries (#12204)
- [ ] Regenerate this pull request now. PiperOrigin-RevId: 599211253 Source-Link: googleapis/googleapis@1654062 Source-Link: googleapis/googleapis-gen@2055a53 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXRhc2tzLy5Pd2xCb3QueWFtbCIsImgiOiIyMDU1YTUzM2FmMTU0ZGNjMjYzZDVjMGJjZDc4YWY4NGI0NGVmMzMyIn0= --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent 9acf675 commit 23e91f5
Copy full SHA for 23e91f5
Expand file treeCollapse file tree

36 files changed

+25
-2813
lines changed

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

Copy file name to clipboardExpand all lines: packages/google-cloud-tasks/google/cloud/tasks/gapic_version.py
+1-1Lines 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__ = "2.15.0" # {x-release-please-version}
16+
__version__ = "0.0.0" # {x-release-please-version}

‎packages/google-cloud-tasks/google/cloud/tasks_v2/gapic_version.py

Copy file name to clipboardExpand all lines: packages/google-cloud-tasks/google/cloud/tasks_v2/gapic_version.py
+1-1Lines 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__ = "2.15.0" # {x-release-please-version}
16+
__version__ = "0.0.0" # {x-release-please-version}

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta2/__init__.py

Copy file name to clipboardExpand all lines: packages/google-cloud-tasks/google/cloud/tasks_v2beta2/__init__.py
-4Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,6 @@
2121
from .services.cloud_tasks import CloudTasksAsyncClient, CloudTasksClient
2222
from .types.cloudtasks import (
2323
AcknowledgeTaskRequest,
24-
BufferTaskRequest,
25-
BufferTaskResponse,
2624
CancelLeaseRequest,
2725
CreateQueueRequest,
2826
CreateTaskRequest,
@@ -69,8 +67,6 @@
6967
"AppEngineHttpTarget",
7068
"AppEngineRouting",
7169
"AttemptStatus",
72-
"BufferTaskRequest",
73-
"BufferTaskResponse",
7470
"CancelLeaseRequest",
7571
"CloudTasksClient",
7672
"CreateQueueRequest",

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta2/gapic_metadata.json

Copy file name to clipboardExpand all lines: packages/google-cloud-tasks/google/cloud/tasks_v2beta2/gapic_metadata.json
-15Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,6 @@
1515
"acknowledge_task"
1616
]
1717
},
18-
"BufferTask": {
19-
"methods": [
20-
"buffer_task"
21-
]
22-
},
2318
"CancelLease": {
2419
"methods": [
2520
"cancel_lease"
@@ -130,11 +125,6 @@
130125
"acknowledge_task"
131126
]
132127
},
133-
"BufferTask": {
134-
"methods": [
135-
"buffer_task"
136-
]
137-
},
138128
"CancelLease": {
139129
"methods": [
140130
"cancel_lease"
@@ -245,11 +235,6 @@
245235
"acknowledge_task"
246236
]
247237
},
248-
"BufferTask": {
249-
"methods": [
250-
"buffer_task"
251-
]
252-
},
253238
"CancelLease": {
254239
"methods": [
255240
"cancel_lease"

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta2/gapic_version.py

Copy file name to clipboardExpand all lines: packages/google-cloud-tasks/google/cloud/tasks_v2beta2/gapic_version.py
+1-1Lines 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__ = "2.15.0" # {x-release-please-version}
16+
__version__ = "0.0.0" # {x-release-please-version}

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta2/services/cloud_tasks/async_client.py

Copy file name to clipboardExpand all lines: packages/google-cloud-tasks/google/cloud/tasks_v2beta2/services/cloud_tasks/async_client.py
-144Lines changed: 0 additions & 144 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@
4242
except AttributeError: # pragma: NO COVER
4343
OptionalRetry = Union[retries.AsyncRetry, object] # type: ignore
4444

45-
from google.api import httpbody_pb2 # type: ignore
4645
from google.cloud.location import locations_pb2 # type: ignore
4746
from google.iam.v1 import iam_policy_pb2 # type: ignore
4847
from google.iam.v1 import policy_pb2 # type: ignore
@@ -2876,149 +2875,6 @@ async def sample_run_task():
28762875
# Done; return the response.
28772876
return response
28782877

2879-
async def buffer_task(
2880-
self,
2881-
request: Optional[Union[cloudtasks.BufferTaskRequest, dict]] = None,
2882-
*,
2883-
queue: Optional[str] = None,
2884-
task_id: Optional[str] = None,
2885-
body: Optional[httpbody_pb2.HttpBody] = None,
2886-
retry: OptionalRetry = gapic_v1.method.DEFAULT,
2887-
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
2888-
metadata: Sequence[Tuple[str, str]] = (),
2889-
) -> cloudtasks.BufferTaskResponse:
2890-
r"""Creates and buffers a new task without the need to explicitly
2891-
define a Task message. The queue must have [HTTP
2892-
target][google.cloud.tasks.v2beta2.HttpTarget]. To create the
2893-
task with a custom ID, use the following format and set TASK_ID
2894-
to your desired ID:
2895-
projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID:buffer
2896-
To create the task with an automatically generated ID, use the
2897-
following format:
2898-
projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks:buffer.
2899-
Note: This feature is in its experimental stage. You must
2900-
request access to the API through the `Cloud Tasks BufferTask
2901-
Experiment Signup form <https://forms.gle/X8Zr5hiXH5tTGFqh8>`__.
2902-
2903-
.. code-block:: python
2904-
2905-
# This snippet has been automatically generated and should be regarded as a
2906-
# code template only.
2907-
# It will require modifications to work:
2908-
# - It may require correct/in-range values for request initialization.
2909-
# - It may require specifying regional endpoints when creating the service
2910-
# client as shown in:
2911-
# https://googleapis.dev/python/google-api-core/latest/client_options.html
2912-
from google.cloud import tasks_v2beta2
2913-
2914-
async def sample_buffer_task():
2915-
# Create a client
2916-
client = tasks_v2beta2.CloudTasksAsyncClient()
2917-
2918-
# Initialize request argument(s)
2919-
request = tasks_v2beta2.BufferTaskRequest(
2920-
queue="queue_value",
2921-
)
2922-
2923-
# Make the request
2924-
response = await client.buffer_task(request=request)
2925-
2926-
# Handle the response
2927-
print(response)
2928-
2929-
Args:
2930-
request (Optional[Union[google.cloud.tasks_v2beta2.types.BufferTaskRequest, dict]]):
2931-
The request object. LINT.IfChange Request message for
2932-
[BufferTask][google.cloud.tasks.v2beta2.CloudTasks.BufferTask].
2933-
queue (:class:`str`):
2934-
Required. The parent queue name. For example:
2935-
projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID\`
2936-
2937-
The queue must already exist.
2938-
2939-
This corresponds to the ``queue`` field
2940-
on the ``request`` instance; if ``request`` is provided, this
2941-
should not be set.
2942-
task_id (:class:`str`):
2943-
Optional. Task ID for the task being
2944-
created. If not provided, a random task
2945-
ID is assigned to the task.
2946-
2947-
This corresponds to the ``task_id`` field
2948-
on the ``request`` instance; if ``request`` is provided, this
2949-
should not be set.
2950-
body (:class:`google.api.httpbody_pb2.HttpBody`):
2951-
Optional. Body of the HTTP request.
2952-
2953-
The body can take any generic value. The value is
2954-
written to the [HttpRequest][payload] of the [Task].
2955-
2956-
This corresponds to the ``body`` field
2957-
on the ``request`` instance; if ``request`` is provided, this
2958-
should not be set.
2959-
retry (google.api_core.retry_async.AsyncRetry): Designation of what errors, if any,
2960-
should be retried.
2961-
timeout (float): The timeout for this request.
2962-
metadata (Sequence[Tuple[str, str]]): Strings which should be
2963-
sent along with the request as metadata.
2964-
2965-
Returns:
2966-
google.cloud.tasks_v2beta2.types.BufferTaskResponse:
2967-
Response message for
2968-
[BufferTask][google.cloud.tasks.v2beta2.CloudTasks.BufferTask].
2969-
2970-
"""
2971-
# Create or coerce a protobuf request object.
2972-
# Quick check: If we got a request object, we should *not* have
2973-
# gotten any keyword arguments that map to the request.
2974-
has_flattened_params = any([queue, task_id, body])
2975-
if request is not None and has_flattened_params:
2976-
raise ValueError(
2977-
"If the `request` argument is set, then none of "
2978-
"the individual field arguments should be set."
2979-
)
2980-
2981-
request = cloudtasks.BufferTaskRequest(request)
2982-
2983-
# If we have keyword arguments corresponding to fields on the
2984-
# request, apply these.
2985-
if queue is not None:
2986-
request.queue = queue
2987-
if task_id is not None:
2988-
request.task_id = task_id
2989-
if body is not None:
2990-
request.body = body
2991-
2992-
# Wrap the RPC method; this adds retry and timeout information,
2993-
# and friendly error handling.
2994-
rpc = gapic_v1.method_async.wrap_method(
2995-
self._client._transport.buffer_task,
2996-
default_timeout=20.0,
2997-
client_info=DEFAULT_CLIENT_INFO,
2998-
)
2999-
3000-
# Certain fields should be provided within the metadata header;
3001-
# add these here.
3002-
metadata = tuple(metadata) + (
3003-
gapic_v1.routing_header.to_grpc_metadata(
3004-
(
3005-
("queue", request.queue),
3006-
("task_id", request.task_id),
3007-
)
3008-
),
3009-
)
3010-
3011-
# Send the request.
3012-
response = await rpc(
3013-
request,
3014-
retry=retry,
3015-
timeout=timeout,
3016-
metadata=metadata,
3017-
)
3018-
3019-
# Done; return the response.
3020-
return response
3021-
30222878
async def get_location(
30232879
self,
30242880
request: Optional[locations_pb2.GetLocationRequest] = None,

‎packages/google-cloud-tasks/google/cloud/tasks_v2beta2/services/cloud_tasks/client.py

Copy file name to clipboardExpand all lines: packages/google-cloud-tasks/google/cloud/tasks_v2beta2/services/cloud_tasks/client.py
-144Lines changed: 0 additions & 144 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,6 @@
4646
except AttributeError: # pragma: NO COVER
4747
OptionalRetry = Union[retries.Retry, object] # type: ignore
4848

49-
from google.api import httpbody_pb2 # type: ignore
5049
from google.cloud.location import locations_pb2 # type: ignore
5150
from google.iam.v1 import iam_policy_pb2 # type: ignore
5251
from google.iam.v1 import policy_pb2 # type: ignore
@@ -3044,149 +3043,6 @@ def sample_run_task():
30443043
# Done; return the response.
30453044
return response
30463045

3047-
def buffer_task(
3048-
self,
3049-
request: Optional[Union[cloudtasks.BufferTaskRequest, dict]] = None,
3050-
*,
3051-
queue: Optional[str] = None,
3052-
task_id: Optional[str] = None,
3053-
body: Optional[httpbody_pb2.HttpBody] = None,
3054-
retry: OptionalRetry = gapic_v1.method.DEFAULT,
3055-
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
3056-
metadata: Sequence[Tuple[str, str]] = (),
3057-
) -> cloudtasks.BufferTaskResponse:
3058-
r"""Creates and buffers a new task without the need to explicitly
3059-
define a Task message. The queue must have [HTTP
3060-
target][google.cloud.tasks.v2beta2.HttpTarget]. To create the
3061-
task with a custom ID, use the following format and set TASK_ID
3062-
to your desired ID:
3063-
projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID:buffer
3064-
To create the task with an automatically generated ID, use the
3065-
following format:
3066-
projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks:buffer.
3067-
Note: This feature is in its experimental stage. You must
3068-
request access to the API through the `Cloud Tasks BufferTask
3069-
Experiment Signup form <https://forms.gle/X8Zr5hiXH5tTGFqh8>`__.
3070-
3071-
.. code-block:: python
3072-
3073-
# This snippet has been automatically generated and should be regarded as a
3074-
# code template only.
3075-
# It will require modifications to work:
3076-
# - It may require correct/in-range values for request initialization.
3077-
# - It may require specifying regional endpoints when creating the service
3078-
# client as shown in:
3079-
# https://googleapis.dev/python/google-api-core/latest/client_options.html
3080-
from google.cloud import tasks_v2beta2
3081-
3082-
def sample_buffer_task():
3083-
# Create a client
3084-
client = tasks_v2beta2.CloudTasksClient()
3085-
3086-
# Initialize request argument(s)
3087-
request = tasks_v2beta2.BufferTaskRequest(
3088-
queue="queue_value",
3089-
)
3090-
3091-
# Make the request
3092-
response = client.buffer_task(request=request)
3093-
3094-
# Handle the response
3095-
print(response)
3096-
3097-
Args:
3098-
request (Union[google.cloud.tasks_v2beta2.types.BufferTaskRequest, dict]):
3099-
The request object. LINT.IfChange Request message for
3100-
[BufferTask][google.cloud.tasks.v2beta2.CloudTasks.BufferTask].
3101-
queue (str):
3102-
Required. The parent queue name. For example:
3103-
projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID\`
3104-
3105-
The queue must already exist.
3106-
3107-
This corresponds to the ``queue`` field
3108-
on the ``request`` instance; if ``request`` is provided, this
3109-
should not be set.
3110-
task_id (str):
3111-
Optional. Task ID for the task being
3112-
created. If not provided, a random task
3113-
ID is assigned to the task.
3114-
3115-
This corresponds to the ``task_id`` field
3116-
on the ``request`` instance; if ``request`` is provided, this
3117-
should not be set.
3118-
body (google.api.httpbody_pb2.HttpBody):
3119-
Optional. Body of the HTTP request.
3120-
3121-
The body can take any generic value. The value is
3122-
written to the [HttpRequest][payload] of the [Task].
3123-
3124-
This corresponds to the ``body`` field
3125-
on the ``request`` instance; if ``request`` is provided, this
3126-
should not be set.
3127-
retry (google.api_core.retry.Retry): Designation of what errors, if any,
3128-
should be retried.
3129-
timeout (float): The timeout for this request.
3130-
metadata (Sequence[Tuple[str, str]]): Strings which should be
3131-
sent along with the request as metadata.
3132-
3133-
Returns:
3134-
google.cloud.tasks_v2beta2.types.BufferTaskResponse:
3135-
Response message for
3136-
[BufferTask][google.cloud.tasks.v2beta2.CloudTasks.BufferTask].
3137-
3138-
"""
3139-
# Create or coerce a protobuf request object.
3140-
# Quick check: If we got a request object, we should *not* have
3141-
# gotten any keyword arguments that map to the request.
3142-
has_flattened_params = any([queue, task_id, body])
3143-
if request is not None and has_flattened_params:
3144-
raise ValueError(
3145-
"If the `request` argument is set, then none of "
3146-
"the individual field arguments should be set."
3147-
)
3148-
3149-
# Minor optimization to avoid making a copy if the user passes
3150-
# in a cloudtasks.BufferTaskRequest.
3151-
# There's no risk of modifying the input as we've already verified
3152-
# there are no flattened fields.
3153-
if not isinstance(request, cloudtasks.BufferTaskRequest):
3154-
request = cloudtasks.BufferTaskRequest(request)
3155-
# If we have keyword arguments corresponding to fields on the
3156-
# request, apply these.
3157-
if queue is not None:
3158-
request.queue = queue
3159-
if task_id is not None:
3160-
request.task_id = task_id
3161-
if body is not None:
3162-
request.body = body
3163-
3164-
# Wrap the RPC method; this adds retry and timeout information,
3165-
# and friendly error handling.
3166-
rpc = self._transport._wrapped_methods[self._transport.buffer_task]
3167-
3168-
# Certain fields should be provided within the metadata header;
3169-
# add these here.
3170-
metadata = tuple(metadata) + (
3171-
gapic_v1.routing_header.to_grpc_metadata(
3172-
(
3173-
("queue", request.queue),
3174-
("task_id", request.task_id),
3175-
)
3176-
),
3177-
)
3178-
3179-
# Send the request.
3180-
response = rpc(
3181-
request,
3182-
retry=retry,
3183-
timeout=timeout,
3184-
metadata=metadata,
3185-
)
3186-
3187-
# Done; return the response.
3188-
return response
3189-
31903046
def __enter__(self) -> "CloudTasksClient":
31913047
return self
31923048

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.