diff --git a/docs/index.rst b/docs/index.rst index dee93e2d9778..d8eca58b9f9e 100644 --- a/docs/index.rst +++ b/docs/index.rst @@ -26,6 +26,7 @@ logging/usage redis/index storage/client + tasks/index texttospeech/index translate/usage vision/index diff --git a/docs/requirements.txt b/docs/requirements.txt index 1879a5959de2..bc25d5497e0c 100644 --- a/docs/requirements.txt +++ b/docs/requirements.txt @@ -27,6 +27,7 @@ resource_manager/ runtimeconfig/ spanner/ speech/ +tasks/ texttospeech/ trace/ translate/ diff --git a/docs/tasks b/docs/tasks new file mode 120000 index 000000000000..5974558b192a --- /dev/null +++ b/docs/tasks @@ -0,0 +1 @@ +../tasks/docs \ No newline at end of file diff --git a/tasks/google/cloud/tasks_v2beta2/gapic/cloud_tasks_client.py b/tasks/google/cloud/tasks_v2beta2/gapic/cloud_tasks_client.py index e29545fb232b..51eac2aeb138 100644 --- a/tasks/google/cloud/tasks_v2beta2/gapic/cloud_tasks_client.py +++ b/tasks/google/cloud/tasks_v2beta2/gapic/cloud_tasks_client.py @@ -17,6 +17,7 @@ import pkg_resources import warnings +from google.oauth2 import service_account import google.api_core.gapic_v1.client_info import google.api_core.gapic_v1.config import google.api_core.gapic_v1.method @@ -57,6 +58,27 @@ class CloudTasksClient(object): # find the method configuration in the client_config dictionary. _INTERFACE_NAME = 'google.cloud.tasks.v2beta2.CloudTasks' + @classmethod + def from_service_account_file(cls, filename, *args, **kwargs): + """Creates an instance of this client using the provided credentials + file. + + Args: + filename (str): The path to the service account private key json + file. + args: Additional arguments to pass to the constructor. + kwargs: Additional arguments to pass to the constructor. + + Returns: + CloudTasksClient: The constructed client. + """ + credentials = service_account.Credentials.from_service_account_file( + filename) + kwargs['credentials'] = credentials + return cls(*args, **kwargs) + + from_service_account_json = from_service_account_file + @classmethod def project_path(cls, project): """Return a fully-qualified project string.""" @@ -156,11 +178,12 @@ def __init__(self, 'Received both a transport instance and ' 'credentials; these are mutually exclusive.') self.transport = transport - self.transport = cloud_tasks_grpc_transport.CloudTasksGrpcTransport( - address=self.SERVICE_ADDRESS, - channel=channel, - credentials=credentials, - ) + else: + self.transport = cloud_tasks_grpc_transport.CloudTasksGrpcTransport( + address=self.SERVICE_ADDRESS, + channel=channel, + credentials=credentials, + ) if client_info is None: client_info = ( @@ -226,7 +249,7 @@ def list_queues(self, described in `Stackdriver's Advanced Logs Filters `_. - Sample filter \"app_engine_http_target: *\". + Sample filter \"app_engine_http_target: \*\". Note that using filters might cause fewer queues than the requested_page size to be returned. @@ -381,7 +404,7 @@ def create_queue(self, WARNING: Using this method may have unintended side effects if you are using an App Engine ``queue.yaml`` or ``queue.xml`` file to manage your queues. Read - `Overview of Queue Management and queue.yaml `_ + `Overview of Queue Management and queue.yaml `_ before using this method. Example: @@ -480,7 +503,7 @@ def update_queue(self, WARNING: Using this method may have unintended side effects if you are using an App Engine ``queue.yaml`` or ``queue.xml`` file to manage your queues. Read - `Overview of Queue Management and queue.yaml `_ + `Overview of Queue Management and queue.yaml `_ before using this method. Example: @@ -575,7 +598,7 @@ def delete_queue(self, WARNING: Using this method may have unintended side effects if you are using an App Engine ``queue.yaml`` or ``queue.xml`` file to manage your queues. Read - `Overview of Queue Management and queue.yaml `_ + `Overview of Queue Management and queue.yaml `_ before using this method. Example: @@ -797,7 +820,7 @@ def resume_queue(self, WARNING: Resuming many high-QPS queues at the same time can lead to target overloading. If you are resuming high-QPS queues, follow the 500/50/5 pattern described in - `Managing Cloud Tasks Scaling Risks `_. + `Managing Cloud Tasks Scaling Risks `_. Example: >>> from google.cloud import tasks_v2beta2 @@ -869,8 +892,9 @@ def get_iam_policy(self, Returns an empty policy if the resource exists and does not have a policy set. - Authorization requires the following `Google IAM `_ permission on the - specified resource parent: + Authorization requires the following + `Google IAM `__ permission on the specified + resource parent: * ``cloudtasks.queues.getIamPolicy`` @@ -946,8 +970,9 @@ def set_iam_policy(self, Note: The Cloud Console does not check queue-level IAM permissions yet. Project-level permissions are required to use the Cloud Console. - Authorization requires the following `Google IAM `_ permission on the - specified resource parent: + Authorization requires the following + `Google IAM `__ permission on the specified + resource parent: * ``cloudtasks.queues.setIamPolicy`` @@ -1110,7 +1135,6 @@ def test_iam_permissions(self, def list_tasks(self, parent, response_view=None, - order_by=None, page_size=None, retry=google.api_core.gapic_v1.method.DEFAULT, timeout=google.api_core.gapic_v1.method.DEFAULT, @@ -1123,6 +1147,9 @@ def list_tasks(self, ``response_view`` controls the subset of information which is returned. + The tasks may be returned in any order. The ordering may change at any + time. + Example: >>> from google.cloud import tasks_v2beta2 >>> @@ -1159,12 +1186,8 @@ def list_tasks(self, contains. Authorization for ``FULL`` requires - ``cloudtasks.tasks.fullView`` `Google IAM `_ permission on the - ``Task`` resource. - order_by (str): Sort order used for the query. The only fields supported for sorting - are ``schedule_time`` and ``pull_message.tag``. All results will be - returned in approximately ascending order. The default ordering is by - ``schedule_time``. + ``cloudtasks.tasks.fullView`` `Google IAM `_ + permission on the ``Task`` resource. page_size (int): The maximum number of resources contained in the underlying API response. If page streaming is performed per- resource, this parameter does not affect the return value. If page @@ -1205,7 +1228,6 @@ def list_tasks(self, request = cloudtasks_pb2.ListTasksRequest( parent=parent, response_view=response_view, - order_by=order_by, page_size=page_size, ) if metadata is None: @@ -1267,8 +1289,8 @@ def get_task(self, contains. Authorization for ``FULL`` requires - ``cloudtasks.tasks.fullView`` `Google IAM `_ permission on the - ``Task`` resource. + ``cloudtasks.tasks.fullView`` `Google IAM `_ + permission on the ``Task`` resource. retry (Optional[google.api_core.retry.Retry]): A retry object used to retry requests. If ``None`` is specified, requests will not be retried. @@ -1329,10 +1351,9 @@ def create_task(self, Tasks cannot be updated after creation; there is no UpdateTask command. - * For `App Engine queues `_, - the maximum task size is 100KB. - * For `pull queues `_, this - the maximum task size is 1MB. + * For ``App Engine queues``, the maximum task size is + 100KB. + * For ``pull queues``, the maximum task size is 1MB. Example: >>> from google.cloud import tasks_v2beta2 @@ -1400,8 +1421,8 @@ def create_task(self, contains. Authorization for ``FULL`` requires - ``cloudtasks.tasks.fullView`` `Google IAM `_ permission on the - ``Task`` resource. + ``cloudtasks.tasks.fullView`` `Google IAM `_ + permission on the ``Task`` resource. retry (Optional[google.api_core.retry.Retry]): A retry object used to retry requests. If ``None`` is specified, requests will not be retried. @@ -1596,8 +1617,8 @@ def lease_tasks(self, contains. Authorization for ``FULL`` requires - ``cloudtasks.tasks.fullView`` `Google IAM `_ permission on the - ``Task`` resource. + ``cloudtasks.tasks.fullView`` `Google IAM `_ + permission on the ``Task`` resource. filter_ (str): ``filter`` can be used to specify a subset of tasks to lease. When ``filter`` is set to ``tag=`` then the @@ -1835,8 +1856,8 @@ def renew_lease(self, contains. Authorization for ``FULL`` requires - ``cloudtasks.tasks.fullView`` `Google IAM `_ permission on the - ``Task`` resource. + ``cloudtasks.tasks.fullView`` `Google IAM `_ + permission on the ``Task`` resource. retry (Optional[google.api_core.retry.Retry]): A retry object used to retry requests. If ``None`` is specified, requests will not be retried. @@ -1938,8 +1959,8 @@ def cancel_lease(self, contains. Authorization for ``FULL`` requires - ``cloudtasks.tasks.fullView`` `Google IAM `_ permission on the - ``Task`` resource. + ``cloudtasks.tasks.fullView`` `Google IAM `_ + permission on the ``Task`` resource. retry (Optional[google.api_core.retry.Retry]): A retry object used to retry requests. If ``None`` is specified, requests will not be retried. @@ -2049,8 +2070,8 @@ def run_task(self, contains. Authorization for ``FULL`` requires - ``cloudtasks.tasks.fullView`` `Google IAM `_ permission on the - ``Task`` resource. + ``cloudtasks.tasks.fullView`` `Google IAM `_ + permission on the ``Task`` resource. retry (Optional[google.api_core.retry.Retry]): A retry object used to retry requests. If ``None`` is specified, requests will not be retried. diff --git a/tasks/google/cloud/tasks_v2beta2/gapic/enums.py b/tasks/google/cloud/tasks_v2beta2/gapic/enums.py index ddbbf5d7d844..05e3e864087b 100644 --- a/tasks/google/cloud/tasks_v2beta2/gapic/enums.py +++ b/tasks/google/cloud/tasks_v2beta2/gapic/enums.py @@ -22,11 +22,11 @@ class HttpMethod(enum.IntEnum): Attributes: HTTP_METHOD_UNSPECIFIED (int): HTTP method unspecified - POST (int): HTTP Post - GET (int): HTTP Get - HEAD (int): HTTP Head - PUT (int): HTTP Put - DELETE (int): HTTP Delete + POST (int): HTTP POST + GET (int): HTTP GET + HEAD (int): HTTP HEAD + PUT (int): HTTP PUT + DELETE (int): HTTP DELETE """ HTTP_METHOD_UNSPECIFIED = 0 POST = 1 @@ -214,7 +214,7 @@ class State(enum.IntEnum): A queue becomes ``DISABLED`` when `queue.yaml `_ or - `queue.xml `_ is uploaded + `queue.xml `_ is uploaded which does not contain the queue. You cannot directly disable a queue. When a queue is disabled, tasks can still be added to a queue diff --git a/tasks/google/cloud/tasks_v2beta2/gapic/transports/cloud_tasks_grpc_transport.py b/tasks/google/cloud/tasks_v2beta2/gapic/transports/cloud_tasks_grpc_transport.py index 3137344f8a41..7cdb6ef5e466 100644 --- a/tasks/google/cloud/tasks_v2beta2/gapic/transports/cloud_tasks_grpc_transport.py +++ b/tasks/google/cloud/tasks_v2beta2/gapic/transports/cloud_tasks_grpc_transport.py @@ -130,7 +130,7 @@ def create_queue(self): WARNING: Using this method may have unintended side effects if you are using an App Engine ``queue.yaml`` or ``queue.xml`` file to manage your queues. Read - `Overview of Queue Management and queue.yaml `_ + `Overview of Queue Management and queue.yaml `_ before using this method. Returns: @@ -156,7 +156,7 @@ def update_queue(self): WARNING: Using this method may have unintended side effects if you are using an App Engine ``queue.yaml`` or ``queue.xml`` file to manage your queues. Read - `Overview of Queue Management and queue.yaml `_ + `Overview of Queue Management and queue.yaml `_ before using this method. Returns: @@ -180,7 +180,7 @@ def delete_queue(self): WARNING: Using this method may have unintended side effects if you are using an App Engine ``queue.yaml`` or ``queue.xml`` file to manage your queues. Read - `Overview of Queue Management and queue.yaml `_ + `Overview of Queue Management and queue.yaml `_ before using this method. Returns: @@ -242,7 +242,7 @@ def resume_queue(self): WARNING: Resuming many high-QPS queues at the same time can lead to target overloading. If you are resuming high-QPS queues, follow the 500/50/5 pattern described in - `Managing Cloud Tasks Scaling Risks `_. + `Managing Cloud Tasks Scaling Risks `_. Returns: Callable: A callable which accepts the appropriate @@ -259,8 +259,9 @@ def get_iam_policy(self): Returns an empty policy if the resource exists and does not have a policy set. - Authorization requires the following `Google IAM `_ permission on the - specified resource parent: + Authorization requires the following + `Google IAM `_ permission on the specified + resource parent: * ``cloudtasks.queues.getIamPolicy`` @@ -281,8 +282,9 @@ def set_iam_policy(self): Note: The Cloud Console does not check queue-level IAM permissions yet. Project-level permissions are required to use the Cloud Console. - Authorization requires the following `Google IAM `_ permission on the - specified resource parent: + Authorization requires the following + `Google IAM `_ permission on the specified + resource parent: * ``cloudtasks.queues.setIamPolicy`` @@ -323,6 +325,9 @@ def list_tasks(self): ``response_view`` controls the subset of information which is returned. + The tasks may be returned in any order. The ordering may change at any + time. + Returns: Callable: A callable which accepts the appropriate deserialized request object and returns a @@ -351,10 +356,9 @@ def create_task(self): Tasks cannot be updated after creation; there is no UpdateTask command. - * For `App Engine queues `_, - the maximum task size is 100KB. - * For `pull queues `_, this - the maximum task size is 1MB. + * For ``App Engine queues``, the maximum task size is + 100KB. + * For ``pull queues``, the maximum task size is 1MB. Returns: Callable: A callable which accepts the appropriate diff --git a/tasks/google/cloud/tasks_v2beta2/proto/cloudtasks_pb2.py b/tasks/google/cloud/tasks_v2beta2/proto/cloudtasks_pb2.py index cb41eb191184..4e86dbd8902f 100644 --- a/tasks/google/cloud/tasks_v2beta2/proto/cloudtasks_pb2.py +++ b/tasks/google/cloud/tasks_v2beta2/proto/cloudtasks_pb2.py @@ -29,7 +29,7 @@ name='google/cloud/tasks_v2beta2/proto/cloudtasks.proto', package='google.cloud.tasks.v2beta2', syntax='proto3', - serialized_pb=_b('\n1google/cloud/tasks_v2beta2/proto/cloudtasks.proto\x12\x1agoogle.cloud.tasks.v2beta2\x1a\x1cgoogle/api/annotations.proto\x1a,google/cloud/tasks_v2beta2/proto/queue.proto\x1a+google/cloud/tasks_v2beta2/proto/task.proto\x1a\x1egoogle/iam/v1/iam_policy.proto\x1a\x1agoogle/iam/v1/policy.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1bgoogle/protobuf/empty.proto\x1a google/protobuf/field_mask.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x15google/rpc/code.proto\"Z\n\x11ListQueuesRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12\x0e\n\x06\x66ilter\x18\x02 \x01(\t\x12\x11\n\tpage_size\x18\x03 \x01(\x05\x12\x12\n\npage_token\x18\x04 \x01(\t\"`\n\x12ListQueuesResponse\x12\x31\n\x06queues\x18\x01 \x03(\x0b\x32!.google.cloud.tasks.v2beta2.Queue\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t\"\x1f\n\x0fGetQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"V\n\x12\x43reateQueueRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12\x30\n\x05queue\x18\x02 \x01(\x0b\x32!.google.cloud.tasks.v2beta2.Queue\"w\n\x12UpdateQueueRequest\x12\x30\n\x05queue\x18\x01 \x01(\x0b\x32!.google.cloud.tasks.v2beta2.Queue\x12/\n\x0bupdate_mask\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.FieldMask\"\"\n\x12\x44\x65leteQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"!\n\x11PurgeQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"!\n\x11PauseQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"\"\n\x12ResumeQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"\x99\x01\n\x10ListTasksRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12<\n\rresponse_view\x18\x02 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\x12\x10\n\x08order_by\x18\x03 \x01(\t\x12\x11\n\tpage_size\x18\x04 \x01(\x05\x12\x12\n\npage_token\x18\x05 \x01(\t\"]\n\x11ListTasksResponse\x12/\n\x05tasks\x18\x01 \x03(\x0b\x32 .google.cloud.tasks.v2beta2.Task\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t\"\\\n\x0eGetTaskRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12<\n\rresponse_view\x18\x02 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\"\x91\x01\n\x11\x43reateTaskRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12.\n\x04task\x18\x02 \x01(\x0b\x32 .google.cloud.tasks.v2beta2.Task\x12<\n\rresponse_view\x18\x03 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\"!\n\x11\x44\x65leteTaskRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"\xb7\x01\n\x11LeaseTasksRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12\x11\n\tmax_tasks\x18\x02 \x01(\x05\x12\x31\n\x0elease_duration\x18\x03 \x01(\x0b\x32\x19.google.protobuf.Duration\x12<\n\rresponse_view\x18\x04 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\x12\x0e\n\x06\x66ilter\x18\x05 \x01(\t\"E\n\x12LeaseTasksResponse\x12/\n\x05tasks\x18\x01 \x03(\x0b\x32 .google.cloud.tasks.v2beta2.Task\"Y\n\x16\x41\x63knowledgeTaskRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\rschedule_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xc5\x01\n\x11RenewLeaseRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\rschedule_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x31\n\x0elease_duration\x18\x03 \x01(\x0b\x32\x19.google.protobuf.Duration\x12<\n\rresponse_view\x18\x04 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\"\x93\x01\n\x12\x43\x61ncelLeaseRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\rschedule_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12<\n\rresponse_view\x18\x03 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\"\\\n\x0eRunTaskRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12<\n\rresponse_view\x18\x02 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View2\xf0\x19\n\nCloudTasks\x12\xa4\x01\n\nListQueues\x12-.google.cloud.tasks.v2beta2.ListQueuesRequest\x1a..google.cloud.tasks.v2beta2.ListQueuesResponse\"7\x82\xd3\xe4\x93\x02\x31\x12//v2beta2/{parent=projects/*/locations/*}/queues\x12\x93\x01\n\x08GetQueue\x12+.google.cloud.tasks.v2beta2.GetQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"7\x82\xd3\xe4\x93\x02\x31\x12//v2beta2/{name=projects/*/locations/*/queues/*}\x12\xa0\x01\n\x0b\x43reateQueue\x12..google.cloud.tasks.v2beta2.CreateQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\">\x82\xd3\xe4\x93\x02\x38\"//v2beta2/{parent=projects/*/locations/*}/queues:\x05queue\x12\xa6\x01\n\x0bUpdateQueue\x12..google.cloud.tasks.v2beta2.UpdateQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"D\x82\xd3\xe4\x93\x02>25/v2beta2/{queue.name=projects/*/locations/*/queues/*}:\x05queue\x12\x8e\x01\n\x0b\x44\x65leteQueue\x12..google.cloud.tasks.v2beta2.DeleteQueueRequest\x1a\x16.google.protobuf.Empty\"7\x82\xd3\xe4\x93\x02\x31*//v2beta2/{name=projects/*/locations/*/queues/*}\x12\xa0\x01\n\nPurgeQueue\x12-.google.cloud.tasks.v2beta2.PurgeQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"@\x82\xd3\xe4\x93\x02:\"5/v2beta2/{name=projects/*/locations/*/queues/*}:purge:\x01*\x12\xa0\x01\n\nPauseQueue\x12-.google.cloud.tasks.v2beta2.PauseQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"@\x82\xd3\xe4\x93\x02:\"5/v2beta2/{name=projects/*/locations/*/queues/*}:pause:\x01*\x12\xa3\x01\n\x0bResumeQueue\x12..google.cloud.tasks.v2beta2.ResumeQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"A\x82\xd3\xe4\x93\x02;\"6/v2beta2/{name=projects/*/locations/*/queues/*}:resume:\x01*\x12\x96\x01\n\x0cGetIamPolicy\x12\".google.iam.v1.GetIamPolicyRequest\x1a\x15.google.iam.v1.Policy\"K\x82\xd3\xe4\x93\x02\x45\"@/v2beta2/{resource=projects/*/locations/*/queues/*}:getIamPolicy:\x01*\x12\x96\x01\n\x0cSetIamPolicy\x12\".google.iam.v1.SetIamPolicyRequest\x1a\x15.google.iam.v1.Policy\"K\x82\xd3\xe4\x93\x02\x45\"@/v2beta2/{resource=projects/*/locations/*/queues/*}:setIamPolicy:\x01*\x12\xbc\x01\n\x12TestIamPermissions\x12(.google.iam.v1.TestIamPermissionsRequest\x1a).google.iam.v1.TestIamPermissionsResponse\"Q\x82\xd3\xe4\x93\x02K\"F/v2beta2/{resource=projects/*/locations/*/queues/*}:testIamPermissions:\x01*\x12\xa9\x01\n\tListTasks\x12,.google.cloud.tasks.v2beta2.ListTasksRequest\x1a-.google.cloud.tasks.v2beta2.ListTasksResponse\"?\x82\xd3\xe4\x93\x02\x39\x12\x37/v2beta2/{parent=projects/*/locations/*/queues/*}/tasks\x12\x98\x01\n\x07GetTask\x12*.google.cloud.tasks.v2beta2.GetTaskRequest\x1a .google.cloud.tasks.v2beta2.Task\"?\x82\xd3\xe4\x93\x02\x39\x12\x37/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}\x12\xa1\x01\n\nCreateTask\x12-.google.cloud.tasks.v2beta2.CreateTaskRequest\x1a .google.cloud.tasks.v2beta2.Task\"B\x82\xd3\xe4\x93\x02<\"7/v2beta2/{parent=projects/*/locations/*/queues/*}/tasks:\x01*\x12\x94\x01\n\nDeleteTask\x12-.google.cloud.tasks.v2beta2.DeleteTaskRequest\x1a\x16.google.protobuf.Empty\"?\x82\xd3\xe4\x93\x02\x39*7/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}\x12\xb5\x01\n\nLeaseTasks\x12-.google.cloud.tasks.v2beta2.LeaseTasksRequest\x1a..google.cloud.tasks.v2beta2.LeaseTasksResponse\"H\x82\xd3\xe4\x93\x02\x42\"=/v2beta2/{parent=projects/*/locations/*/queues/*}/tasks:lease:\x01*\x12\xad\x01\n\x0f\x41\x63knowledgeTask\x12\x32.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest\x1a\x16.google.protobuf.Empty\"N\x82\xd3\xe4\x93\x02H\"C/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}:acknowledge:\x01*\x12\xac\x01\n\nRenewLease\x12-.google.cloud.tasks.v2beta2.RenewLeaseRequest\x1a .google.cloud.tasks.v2beta2.Task\"M\x82\xd3\xe4\x93\x02G\"B/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}:renewLease:\x01*\x12\xaf\x01\n\x0b\x43\x61ncelLease\x12..google.cloud.tasks.v2beta2.CancelLeaseRequest\x1a .google.cloud.tasks.v2beta2.Task\"N\x82\xd3\xe4\x93\x02H\"C/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}:cancelLease:\x01*\x12\x9f\x01\n\x07RunTask\x12*.google.cloud.tasks.v2beta2.RunTaskRequest\x1a .google.cloud.tasks.v2beta2.Task\"F\x82\xd3\xe4\x93\x02@\";/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}:run:\x01*B|\n\x1e\x63om.google.cloud.tasks.v2beta2B\x0f\x43loudTasksProtoP\x01Z?google.golang.org/genproto/googleapis/cloud/tasks/v2beta2;tasks\xa2\x02\x05TASKSb\x06proto3') + serialized_pb=_b('\n1google/cloud/tasks_v2beta2/proto/cloudtasks.proto\x12\x1agoogle.cloud.tasks.v2beta2\x1a\x1cgoogle/api/annotations.proto\x1a,google/cloud/tasks_v2beta2/proto/queue.proto\x1a+google/cloud/tasks_v2beta2/proto/task.proto\x1a\x1egoogle/iam/v1/iam_policy.proto\x1a\x1agoogle/iam/v1/policy.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1bgoogle/protobuf/empty.proto\x1a google/protobuf/field_mask.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x15google/rpc/code.proto\"Z\n\x11ListQueuesRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12\x0e\n\x06\x66ilter\x18\x02 \x01(\t\x12\x11\n\tpage_size\x18\x03 \x01(\x05\x12\x12\n\npage_token\x18\x04 \x01(\t\"`\n\x12ListQueuesResponse\x12\x31\n\x06queues\x18\x01 \x03(\x0b\x32!.google.cloud.tasks.v2beta2.Queue\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t\"\x1f\n\x0fGetQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"V\n\x12\x43reateQueueRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12\x30\n\x05queue\x18\x02 \x01(\x0b\x32!.google.cloud.tasks.v2beta2.Queue\"w\n\x12UpdateQueueRequest\x12\x30\n\x05queue\x18\x01 \x01(\x0b\x32!.google.cloud.tasks.v2beta2.Queue\x12/\n\x0bupdate_mask\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.FieldMask\"\"\n\x12\x44\x65leteQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"!\n\x11PurgeQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"!\n\x11PauseQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"\"\n\x12ResumeQueueRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"\x87\x01\n\x10ListTasksRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12<\n\rresponse_view\x18\x02 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\x12\x11\n\tpage_size\x18\x04 \x01(\x05\x12\x12\n\npage_token\x18\x05 \x01(\t\"]\n\x11ListTasksResponse\x12/\n\x05tasks\x18\x01 \x03(\x0b\x32 .google.cloud.tasks.v2beta2.Task\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t\"\\\n\x0eGetTaskRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12<\n\rresponse_view\x18\x02 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\"\x91\x01\n\x11\x43reateTaskRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12.\n\x04task\x18\x02 \x01(\x0b\x32 .google.cloud.tasks.v2beta2.Task\x12<\n\rresponse_view\x18\x03 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\"!\n\x11\x44\x65leteTaskRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"\xb7\x01\n\x11LeaseTasksRequest\x12\x0e\n\x06parent\x18\x01 \x01(\t\x12\x11\n\tmax_tasks\x18\x02 \x01(\x05\x12\x31\n\x0elease_duration\x18\x03 \x01(\x0b\x32\x19.google.protobuf.Duration\x12<\n\rresponse_view\x18\x04 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\x12\x0e\n\x06\x66ilter\x18\x05 \x01(\t\"E\n\x12LeaseTasksResponse\x12/\n\x05tasks\x18\x01 \x03(\x0b\x32 .google.cloud.tasks.v2beta2.Task\"Y\n\x16\x41\x63knowledgeTaskRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\rschedule_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xc5\x01\n\x11RenewLeaseRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\rschedule_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x31\n\x0elease_duration\x18\x03 \x01(\x0b\x32\x19.google.protobuf.Duration\x12<\n\rresponse_view\x18\x04 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\"\x93\x01\n\x12\x43\x61ncelLeaseRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x31\n\rschedule_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12<\n\rresponse_view\x18\x03 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View\"\\\n\x0eRunTaskRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12<\n\rresponse_view\x18\x02 \x01(\x0e\x32%.google.cloud.tasks.v2beta2.Task.View2\xf0\x19\n\nCloudTasks\x12\xa4\x01\n\nListQueues\x12-.google.cloud.tasks.v2beta2.ListQueuesRequest\x1a..google.cloud.tasks.v2beta2.ListQueuesResponse\"7\x82\xd3\xe4\x93\x02\x31\x12//v2beta2/{parent=projects/*/locations/*}/queues\x12\x93\x01\n\x08GetQueue\x12+.google.cloud.tasks.v2beta2.GetQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"7\x82\xd3\xe4\x93\x02\x31\x12//v2beta2/{name=projects/*/locations/*/queues/*}\x12\xa0\x01\n\x0b\x43reateQueue\x12..google.cloud.tasks.v2beta2.CreateQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\">\x82\xd3\xe4\x93\x02\x38\"//v2beta2/{parent=projects/*/locations/*}/queues:\x05queue\x12\xa6\x01\n\x0bUpdateQueue\x12..google.cloud.tasks.v2beta2.UpdateQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"D\x82\xd3\xe4\x93\x02>25/v2beta2/{queue.name=projects/*/locations/*/queues/*}:\x05queue\x12\x8e\x01\n\x0b\x44\x65leteQueue\x12..google.cloud.tasks.v2beta2.DeleteQueueRequest\x1a\x16.google.protobuf.Empty\"7\x82\xd3\xe4\x93\x02\x31*//v2beta2/{name=projects/*/locations/*/queues/*}\x12\xa0\x01\n\nPurgeQueue\x12-.google.cloud.tasks.v2beta2.PurgeQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"@\x82\xd3\xe4\x93\x02:\"5/v2beta2/{name=projects/*/locations/*/queues/*}:purge:\x01*\x12\xa0\x01\n\nPauseQueue\x12-.google.cloud.tasks.v2beta2.PauseQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"@\x82\xd3\xe4\x93\x02:\"5/v2beta2/{name=projects/*/locations/*/queues/*}:pause:\x01*\x12\xa3\x01\n\x0bResumeQueue\x12..google.cloud.tasks.v2beta2.ResumeQueueRequest\x1a!.google.cloud.tasks.v2beta2.Queue\"A\x82\xd3\xe4\x93\x02;\"6/v2beta2/{name=projects/*/locations/*/queues/*}:resume:\x01*\x12\x96\x01\n\x0cGetIamPolicy\x12\".google.iam.v1.GetIamPolicyRequest\x1a\x15.google.iam.v1.Policy\"K\x82\xd3\xe4\x93\x02\x45\"@/v2beta2/{resource=projects/*/locations/*/queues/*}:getIamPolicy:\x01*\x12\x96\x01\n\x0cSetIamPolicy\x12\".google.iam.v1.SetIamPolicyRequest\x1a\x15.google.iam.v1.Policy\"K\x82\xd3\xe4\x93\x02\x45\"@/v2beta2/{resource=projects/*/locations/*/queues/*}:setIamPolicy:\x01*\x12\xbc\x01\n\x12TestIamPermissions\x12(.google.iam.v1.TestIamPermissionsRequest\x1a).google.iam.v1.TestIamPermissionsResponse\"Q\x82\xd3\xe4\x93\x02K\"F/v2beta2/{resource=projects/*/locations/*/queues/*}:testIamPermissions:\x01*\x12\xa9\x01\n\tListTasks\x12,.google.cloud.tasks.v2beta2.ListTasksRequest\x1a-.google.cloud.tasks.v2beta2.ListTasksResponse\"?\x82\xd3\xe4\x93\x02\x39\x12\x37/v2beta2/{parent=projects/*/locations/*/queues/*}/tasks\x12\x98\x01\n\x07GetTask\x12*.google.cloud.tasks.v2beta2.GetTaskRequest\x1a .google.cloud.tasks.v2beta2.Task\"?\x82\xd3\xe4\x93\x02\x39\x12\x37/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}\x12\xa1\x01\n\nCreateTask\x12-.google.cloud.tasks.v2beta2.CreateTaskRequest\x1a .google.cloud.tasks.v2beta2.Task\"B\x82\xd3\xe4\x93\x02<\"7/v2beta2/{parent=projects/*/locations/*/queues/*}/tasks:\x01*\x12\x94\x01\n\nDeleteTask\x12-.google.cloud.tasks.v2beta2.DeleteTaskRequest\x1a\x16.google.protobuf.Empty\"?\x82\xd3\xe4\x93\x02\x39*7/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}\x12\xb5\x01\n\nLeaseTasks\x12-.google.cloud.tasks.v2beta2.LeaseTasksRequest\x1a..google.cloud.tasks.v2beta2.LeaseTasksResponse\"H\x82\xd3\xe4\x93\x02\x42\"=/v2beta2/{parent=projects/*/locations/*/queues/*}/tasks:lease:\x01*\x12\xad\x01\n\x0f\x41\x63knowledgeTask\x12\x32.google.cloud.tasks.v2beta2.AcknowledgeTaskRequest\x1a\x16.google.protobuf.Empty\"N\x82\xd3\xe4\x93\x02H\"C/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}:acknowledge:\x01*\x12\xac\x01\n\nRenewLease\x12-.google.cloud.tasks.v2beta2.RenewLeaseRequest\x1a .google.cloud.tasks.v2beta2.Task\"M\x82\xd3\xe4\x93\x02G\"B/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}:renewLease:\x01*\x12\xaf\x01\n\x0b\x43\x61ncelLease\x12..google.cloud.tasks.v2beta2.CancelLeaseRequest\x1a .google.cloud.tasks.v2beta2.Task\"N\x82\xd3\xe4\x93\x02H\"C/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}:cancelLease:\x01*\x12\x9f\x01\n\x07RunTask\x12*.google.cloud.tasks.v2beta2.RunTaskRequest\x1a .google.cloud.tasks.v2beta2.Task\"F\x82\xd3\xe4\x93\x02@\";/v2beta2/{name=projects/*/locations/*/queues/*/tasks/*}:run:\x01*B|\n\x1e\x63om.google.cloud.tasks.v2beta2B\x0f\x43loudTasksProtoP\x01Z?google.golang.org/genproto/googleapis/cloud/tasks/v2beta2;tasks\xa2\x02\x05TASKSb\x06proto3') , dependencies=[google_dot_api_dot_annotations__pb2.DESCRIPTOR,google_dot_cloud_dot_tasks__v2beta2_dot_proto_dot_queue__pb2.DESCRIPTOR,google_dot_cloud_dot_tasks__v2beta2_dot_proto_dot_task__pb2.DESCRIPTOR,google_dot_iam_dot_v1_dot_iam__policy__pb2.DESCRIPTOR,google_dot_iam_dot_v1_dot_policy__pb2.DESCRIPTOR,google_dot_protobuf_dot_duration__pb2.DESCRIPTOR,google_dot_protobuf_dot_empty__pb2.DESCRIPTOR,google_dot_protobuf_dot_field__mask__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,google_dot_rpc_dot_code__pb2.DESCRIPTOR,]) @@ -379,21 +379,14 @@ is_extension=False, extension_scope=None, options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( - name='order_by', full_name='google.cloud.tasks.v2beta2.ListTasksRequest.order_by', index=2, - number=3, type=9, cpp_type=9, label=1, - has_default_value=False, default_value=_b("").decode('utf-8'), - message_type=None, enum_type=None, containing_type=None, - is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), - _descriptor.FieldDescriptor( - name='page_size', full_name='google.cloud.tasks.v2beta2.ListTasksRequest.page_size', index=3, + name='page_size', full_name='google.cloud.tasks.v2beta2.ListTasksRequest.page_size', index=2, number=4, type=5, cpp_type=1, label=1, has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( - name='page_token', full_name='google.cloud.tasks.v2beta2.ListTasksRequest.page_token', index=4, + name='page_token', full_name='google.cloud.tasks.v2beta2.ListTasksRequest.page_token', index=3, number=5, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, @@ -412,7 +405,7 @@ oneofs=[ ], serialized_start=988, - serialized_end=1141, + serialized_end=1123, ) @@ -449,8 +442,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1143, - serialized_end=1236, + serialized_start=1125, + serialized_end=1218, ) @@ -487,8 +480,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1238, - serialized_end=1330, + serialized_start=1220, + serialized_end=1312, ) @@ -532,8 +525,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1333, - serialized_end=1478, + serialized_start=1315, + serialized_end=1460, ) @@ -563,8 +556,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1480, - serialized_end=1513, + serialized_start=1462, + serialized_end=1495, ) @@ -622,8 +615,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1516, - serialized_end=1699, + serialized_start=1498, + serialized_end=1681, ) @@ -653,8 +646,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1701, - serialized_end=1770, + serialized_start=1683, + serialized_end=1752, ) @@ -691,8 +684,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1772, - serialized_end=1861, + serialized_start=1754, + serialized_end=1843, ) @@ -743,8 +736,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1864, - serialized_end=2061, + serialized_start=1846, + serialized_end=2043, ) @@ -788,8 +781,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=2064, - serialized_end=2211, + serialized_start=2046, + serialized_end=2193, ) @@ -826,8 +819,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=2213, - serialized_end=2305, + serialized_start=2195, + serialized_end=2287, ) _LISTQUEUESRESPONSE.fields_by_name['queues'].message_type = google_dot_cloud_dot_tasks__v2beta2_dot_proto_dot_queue__pb2._QUEUE @@ -888,11 +881,11 @@ [Queue][google.cloud.tasks.v2beta2.Queue] field can be used as a filter and several operators as supported. For example: ``<=, <, >=, >, !=, =, :``. The filter syntax is the same as - described in `Stackdriver's Advanced Logs Filters - `__. Sample filter - "app\_engine\_http\_target: \*". Note that using filters - might cause fewer queues than the requested\_page size to be - returned. + described in `Stackdriver's Advanced Logs Filters `_. Sample + filter "app\_engine\_http\_target: \*". Note that using + filters might cause fewer queues than the requested\_page size + to be returned. page_size: Requested page size. The maximum page size is 9800. If unspecified, the page size will be the maximum. Fewer queues @@ -1096,14 +1089,9 @@ because of its large size or because of the sensitivity of data that it contains. Authorization for [FULL][google.cloud.tasks.v2beta2.Task.View.FULL] requires - ``cloudtasks.tasks.fullView`` `Google IAM `__ - permission on the [Task][google.cloud.tasks.v2beta2.Task] - resource. - order_by: - Sort order used for the query. The only fields supported for - sorting are ``schedule_time`` and ``pull_message.tag``. All - results will be returned in approximately ascending order. The - default ordering is by ``schedule_time``. + ``cloudtasks.tasks.fullView`` `Google IAM + `_ permission on the + [Task][google.cloud.tasks.v2beta2.Task] resource. page_size: Requested page size. Fewer tasks than requested might be returned. The maximum page size is 1000. If unspecified, the @@ -1169,9 +1157,9 @@ because of its large size or because of the sensitivity of data that it contains. Authorization for [FULL][google.cloud.tasks.v2beta2.Task.View.FULL] requires - ``cloudtasks.tasks.fullView`` `Google IAM `__ - permission on the [Task][google.cloud.tasks.v2beta2.Task] - resource. + ``cloudtasks.tasks.fullView`` `Google IAM + `_ permission on the + [Task][google.cloud.tasks.v2beta2.Task] resource. """, # @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.GetTaskRequest) )) @@ -1230,9 +1218,9 @@ because of its large size or because of the sensitivity of data that it contains. Authorization for [FULL][google.cloud.tasks.v2beta2.Task.View.FULL] requires - ``cloudtasks.tasks.fullView`` `Google IAM `__ - permission on the [Task][google.cloud.tasks.v2beta2.Task] - resource. + ``cloudtasks.tasks.fullView`` `Google IAM + `_ permission on the + [Task][google.cloud.tasks.v2beta2.Task] resource. """, # @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.CreateTaskRequest) )) @@ -1291,9 +1279,9 @@ because of its large size or because of the sensitivity of data that it contains. Authorization for [FULL][google.cloud.tasks.v2beta2.Task.View.FULL] requires - ``cloudtasks.tasks.fullView`` `Google IAM `__ - permission on the [Task][google.cloud.tasks.v2beta2.Task] - resource. + ``cloudtasks.tasks.fullView`` `Google IAM + `_ permission on the + [Task][google.cloud.tasks.v2beta2.Task] resource. filter: ``filter`` can be used to specify a subset of tasks to lease. When ``filter`` is set to ``tag=`` then the @@ -1309,11 +1297,11 @@ = "oldest_tag()"`` The ``oldest_tag()`` function returns tasks which have the same tag as the oldest task (ordered by schedule time). SDK compatibility: Although the SDK allows - tags to be either string or `bytes `__, only UTF-8 encoded tags can be used in - Cloud Tasks. Tag which aren't UTF-8 encoded can't be used in - the + tags to be either string or `bytes `_, only UTF-8 encoded + tags can be used in Cloud Tasks. Tag which aren't UTF-8 + encoded can't be used in the [filter][google.cloud.tasks.v2beta2.LeaseTasksRequest.filter] and the task's [tag][google.cloud.tasks.v2beta2.PullMessage.tag] will be @@ -1400,9 +1388,9 @@ because of its large size or because of the sensitivity of data that it contains. Authorization for [FULL][google.cloud.tasks.v2beta2.Task.View.FULL] requires - ``cloudtasks.tasks.fullView`` `Google IAM `__ - permission on the [Task][google.cloud.tasks.v2beta2.Task] - resource. + ``cloudtasks.tasks.fullView`` `Google IAM + `_ permission on the + [Task][google.cloud.tasks.v2beta2.Task] resource. """, # @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.RenewLeaseRequest) )) @@ -1439,9 +1427,9 @@ because of its large size or because of the sensitivity of data that it contains. Authorization for [FULL][google.cloud.tasks.v2beta2.Task.View.FULL] requires - ``cloudtasks.tasks.fullView`` `Google IAM `__ - permission on the [Task][google.cloud.tasks.v2beta2.Task] - resource. + ``cloudtasks.tasks.fullView`` `Google IAM + `_ permission on the + [Task][google.cloud.tasks.v2beta2.Task] resource. """, # @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.CancelLeaseRequest) )) @@ -1469,9 +1457,9 @@ because of its large size or because of the sensitivity of data that it contains. Authorization for [FULL][google.cloud.tasks.v2beta2.Task.View.FULL] requires - ``cloudtasks.tasks.fullView`` `Google IAM `__ - permission on the [Task][google.cloud.tasks.v2beta2.Task] - resource. + ``cloudtasks.tasks.fullView`` `Google IAM + `_ permission on the + [Task][google.cloud.tasks.v2beta2.Task] resource. """, # @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.RunTaskRequest) )) @@ -1487,8 +1475,8 @@ file=DESCRIPTOR, index=0, options=None, - serialized_start=2308, - serialized_end=5620, + serialized_start=2290, + serialized_end=5602, methods=[ _descriptor.MethodDescriptor( name='ListQueues', diff --git a/tasks/google/cloud/tasks_v2beta2/proto/cloudtasks_pb2_grpc.py b/tasks/google/cloud/tasks_v2beta2/proto/cloudtasks_pb2_grpc.py index 19627e6378c1..b19afaae54bd 100644 --- a/tasks/google/cloud/tasks_v2beta2/proto/cloudtasks_pb2_grpc.py +++ b/tasks/google/cloud/tasks_v2beta2/proto/cloudtasks_pb2_grpc.py @@ -153,7 +153,7 @@ def CreateQueue(self, request, context): WARNING: Using this method may have unintended side effects if you are using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. Read - [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml) + [Overview of Queue Management and queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using this method. """ context.set_code(grpc.StatusCode.UNIMPLEMENTED) @@ -173,7 +173,7 @@ def UpdateQueue(self, request, context): WARNING: Using this method may have unintended side effects if you are using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. Read - [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml) + [Overview of Queue Management and queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using this method. """ context.set_code(grpc.StatusCode.UNIMPLEMENTED) @@ -191,7 +191,7 @@ def DeleteQueue(self, request, context): WARNING: Using this method may have unintended side effects if you are using an App Engine `queue.yaml` or `queue.xml` file to manage your queues. Read - [Overview of Queue Management and queue.yaml](/cloud-tasks/docs/queue-yaml) + [Overview of Queue Management and queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using this method. """ context.set_code(grpc.StatusCode.UNIMPLEMENTED) @@ -235,7 +235,7 @@ def ResumeQueue(self, request, context): WARNING: Resuming many high-QPS queues at the same time can lead to target overloading. If you are resuming high-QPS queues, follow the 500/50/5 pattern described in - [Managing Cloud Tasks Scaling Risks](/cloud-tasks/pdfs/managing-cloud-tasks-scaling-risks-2017-06-05.pdf). + [Managing Cloud Tasks Scaling Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling). """ context.set_code(grpc.StatusCode.UNIMPLEMENTED) context.set_details('Method not implemented!') @@ -246,8 +246,9 @@ def GetIamPolicy(self, request, context): Returns an empty policy if the resource exists and does not have a policy set. - Authorization requires the following [Google IAM](/iam) permission on the - specified resource parent: + Authorization requires the following + [Google IAM](https://cloud.google.com/iam) permission on the specified + resource parent: * `cloudtasks.queues.getIamPolicy` """ @@ -262,8 +263,9 @@ def SetIamPolicy(self, request, context): Note: The Cloud Console does not check queue-level IAM permissions yet. Project-level permissions are required to use the Cloud Console. - Authorization requires the following [Google IAM](/iam) permission on the - specified resource parent: + Authorization requires the following + [Google IAM](https://cloud.google.com/iam) permission on the specified + resource parent: * `cloudtasks.queues.setIamPolicy` """ @@ -291,6 +293,9 @@ def ListTasks(self, request, context): due to performance considerations; [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] controls the subset of information which is returned. + + The tasks may be returned in any order. The ordering may change at any + time. """ context.set_code(grpc.StatusCode.UNIMPLEMENTED) context.set_details('Method not implemented!') @@ -308,10 +313,9 @@ def CreateTask(self, request, context): Tasks cannot be updated after creation; there is no UpdateTask command. - * For [App Engine queues](google.cloud.tasks.v2beta2.AppEngineHttpTarget), - the maximum task size is 100KB. - * For [pull queues](google.cloud.tasks.v2beta2.PullTarget), this - the maximum task size is 1MB. + * For [App Engine queues][google.cloud.tasks.v2beta2.AppEngineHttpTarget], the maximum task size is + 100KB. + * For [pull queues][google.cloud.tasks.v2beta2.PullTarget], the maximum task size is 1MB. """ context.set_code(grpc.StatusCode.UNIMPLEMENTED) context.set_details('Method not implemented!') diff --git a/tasks/google/cloud/tasks_v2beta2/proto/queue_pb2.py b/tasks/google/cloud/tasks_v2beta2/proto/queue_pb2.py index 241dfba4f0f8..3306acc9c7e8 100644 --- a/tasks/google/cloud/tasks_v2beta2/proto/queue_pb2.py +++ b/tasks/google/cloud/tasks_v2beta2/proto/queue_pb2.py @@ -295,10 +295,10 @@ ``projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID`` - ``PROJECT_ID`` can contain letters ([A-Za-z]), numbers ([0-9]), hyphens (-), colons (:), or periods (.). For more - information, see `Identifying projects `__ - ``LOCATION_ID`` is the - canonical ID for the queue's location. The list of + information, see `Identifying projects + `_ - ``LOCATION_ID`` + is the canonical ID for the queue's location. The list of available locations can be obtained by calling [ListLocatio ns][google.cloud.location.Locations.ListLocations]. For more information, see @@ -343,26 +343,25 @@ retry settings apply to all tasks in the queue which do not have retry settings explicitly set on the task and were created by the App Engine SDK. See `App Engine - documentation - `__. + documentation `_. state: Output only. The state of the queue. ``state`` can only be changed by called [PauseQueue][google.cloud.tasks.v2beta2.Clou dTasks.PauseQueue], [ResumeQueue][google.cloud.tasks.v2beta2.C - loudTasks.ResumeQueue], or uploading `queue.yaml/xml - `__. [UpdateQueue][goo - gle.cloud.tasks.v2beta2.CloudTasks.UpdateQueue] cannot be used - to change ``state``. + loudTasks.ResumeQueue], or uploading `queue.yaml/xml `_. [U + pdateQueue][google.cloud.tasks.v2beta2.CloudTasks.UpdateQueue] + cannot be used to change ``state``. purge_time: Output only. The last time this queue was purged. All tasks that were [created][google.cloud.tasks.v2beta2.Task.create\_time] before this time were purged. A queue can be purged using [PurgeQueu e][google.cloud.tasks.v2beta2.CloudTasks.PurgeQueue], the `App - Engine Task Queue SDK, or the Cloud Console - `__. Purge + Engine Task Queue SDK, or the Cloud Console `_. Purge time will be truncated to the nearest microsecond. Purge time will be unset if the queue has never been purged. """, @@ -390,15 +389,16 @@ max_tasks_dispatched_per_second: The maximum rate at which tasks are dispatched from this queue. If unspecified when the queue is created, Cloud Tasks - will pick the default. - For App Engine queues, the maximum - allowed value is 500. - This field is output only for `pull - queues `__. In addition - to the ``max_tasks_dispatched_per_second`` limit, a maximum - of 10 QPS of + will pick the default. - For [App Engine + queues][google.cloud.tasks.v2beta2.AppEngineHttpTarget], the + maximum allowed value is 500. - This field is output only + for [pull queues][google.cloud.tasks.v2beta2.PullTarget]. + In addition to the ``max_tasks_dispatched_per_second`` + limit, a maximum of 10 QPS of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] requests are allowed per pull queue. This field has the same - meaning as `rate in queue.yaml/xml - `__. + meaning as `rate in queue.yaml/xml `_. max_burst_size: Output only. The max burst size. Max burst size limits how fast tasks in queue are processed when many tasks are in the @@ -406,7 +406,7 @@ have a high rate so processing starts shortly after a task is enqueued, but still limits resource usage when many tasks are enqueued in a short period of time. The `token bucket - `__ algorithm is used + `_ algorithm is used to control the rate of task dispatches. Each queue has a token bucket that holds tokens, up to the maximum specified by ``max_burst_size``. Each time a task is dispatched, a token is @@ -419,16 +419,17 @@ sks\_dispatched\_per\_second][google.cloud.tasks.v2beta2.RateL imits.max\_tasks\_dispatched\_per\_second]. For App Engine queues that were created or updated using ``queue.yaml/xml``, - ``max_burst_size`` is equal to `bucket\_size `__. Since - ``max_burst_size`` is output only, if [UpdateQueue][google.clo - ud.tasks.v2beta2.CloudTasks.UpdateQueue] is called on a queue - created by ``queue.yaml/xml``, ``max_burst_size`` will be - reset based on the value of [max\_tasks\_dispatched\_per\_seco - nd][google.cloud.tasks.v2beta2.RateLimits.max\_tasks\_dispatch - ed\_per\_second], regardless of whether [max\_tasks\_dispatche - d\_per\_second][google.cloud.tasks.v2beta2.RateLimits.max\_tas - ks\_dispatched\_per\_second] is updated. + ``max_burst_size`` is equal to `bucket\_size `_. Since ``max_burst_size`` is output only, if [Update + Queue][google.cloud.tasks.v2beta2.CloudTasks.UpdateQueue] is + called on a queue created by ``queue.yaml/xml``, + ``max_burst_size`` will be reset based on the value of [max\_t + asks\_dispatched\_per\_second][google.cloud.tasks.v2beta2.Rate + Limits.max\_tasks\_dispatched\_per\_second], regardless of + whether [max\_tasks\_dispatched\_per\_second][google.cloud.tas + ks.v2beta2.RateLimits.max\_tasks\_dispatched\_per\_second] is + updated. max_concurrent_tasks: The maximum number of concurrent tasks that Cloud Tasks allows to be dispatched for this queue. After this threshold has been @@ -436,12 +437,12 @@ of concurrent requests decreases. If unspecified when the queue is created, Cloud Tasks will pick the default. The maximum allowed value is 5,000. This field is output only for - `pull queues `__ and + [pull queues][google.cloud.tasks.v2beta2.PullTarget] and always -1, which indicates no limit. No other queue types can have ``max_concurrent_tasks`` set to -1. This field has the - same meaning as `max\_concurrent\_requests in queue.yaml/xml < - /appengine/docs/standard/python/config/queueref#max_concurrent - _requests>`__. + same meaning as `max\_concurrent\_requests in queue.yaml/xml + `_. """, # @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.RateLimits) )) @@ -460,9 +461,9 @@ num_attempts: Number of attempts per task. If unspecified when the queue is created, Cloud Tasks will pick the default. This field has - the same meaning as `task\_retry\_limit in queue.yaml/xml - `__. + the same meaning as `task\_retry\_limit in queue.yaml/xml `_. max_attempts: The maximum number of attempts for a task. Cloud Tasks will attempt the task ``max_attempts`` times (that is, if the first @@ -479,40 +480,44 @@ attempts will be made and the task will be deleted. If zero, then the task age is unlimited. If unspecified when the queue is created, Cloud Tasks will pick the default. This field is - output only for `pull queues - `__. + output only for [pull + queues][google.cloud.tasks.v2beta2.PullTarget]. ``max_retry_duration`` will be truncated to the nearest second. This field has the same meaning as `task\_age\_limit - in queue.yaml/xml `__. + in queue.yaml/xml `_. min_backoff: - A task will be `scheduled `__ for retry - between [min\_backoff][google.cloud.tasks.v2beta2.RetryConfig. - min\_backoff] and [max\_backoff][google.cloud.tasks.v2beta2.Re - tryConfig.max\_backoff] duration after it fails, if the - queue's [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig] + A task will be + [scheduled][google.cloud.tasks.v2beta2.Task.schedule\_time] + for retry between [min\_backoff][google.cloud.tasks.v2beta2.Re + tryConfig.min\_backoff] and [max\_backoff][google.cloud.tasks. + v2beta2.RetryConfig.max\_backoff] duration after it fails, if + the queue's + [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig] specifies that the task should be retried. If unspecified when the queue is created, Cloud Tasks will pick the default. - This field is output only for `pull queues - `__. ``min_backoff`` - will be truncated to the nearest second. This field has the - same meaning as `min\_backoff\_seconds in queue.yaml/xml ` - __. + This field is output only for [pull + queues][google.cloud.tasks.v2beta2.PullTarget]. + ``min_backoff`` will be truncated to the nearest second. This + field has the same meaning as `min\_backoff\_seconds in + queue.yaml/xml `_. max_backoff: - A task will be `scheduled `__ for retry - between [min\_backoff][google.cloud.tasks.v2beta2.RetryConfig. - min\_backoff] and [max\_backoff][google.cloud.tasks.v2beta2.Re - tryConfig.max\_backoff] duration after it fails, if the - queue's [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig] + A task will be + [scheduled][google.cloud.tasks.v2beta2.Task.schedule\_time] + for retry between [min\_backoff][google.cloud.tasks.v2beta2.Re + tryConfig.min\_backoff] and [max\_backoff][google.cloud.tasks. + v2beta2.RetryConfig.max\_backoff] duration after it fails, if + the queue's + [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig] specifies that the task should be retried. If unspecified when the queue is created, Cloud Tasks will pick the default. - This field is output only for `pull queues - `__. ``max_backoff`` - will be truncated to the nearest second. This field has the - same meaning as `max\_backoff\_seconds in queue.yaml/xml ` - __. + This field is output only for [pull + queues][google.cloud.tasks.v2beta2.PullTarget]. + ``max_backoff`` will be truncated to the nearest second. This + field has the same meaning as `max\_backoff\_seconds in + queue.yaml/xml `_. max_doublings: The time between retries will double ``max_doublings`` times. A task's retry interval starts at [min\_backoff][google.cloud. @@ -533,10 +538,11 @@ ] times. Thus, the requests will retry at 10s, 20s, 40s, 80s, 160s, 240s, 300s, 300s, .... If unspecified when the queue is created, Cloud Tasks will pick the default. This field is - output only for `pull queues - `__. This field has - the same meaning as `max\_doublings in queue.yaml/xml `__. + output only for [pull + queues][google.cloud.tasks.v2beta2.PullTarget]. This field + has the same meaning as `max\_doublings in queue.yaml/xml `_. """, # @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.RetryConfig) )) diff --git a/tasks/google/cloud/tasks_v2beta2/proto/target_pb2.py b/tasks/google/cloud/tasks_v2beta2/proto/target_pb2.py index f4aa1f0a7f0b..bdcb0b9e2c97 100644 --- a/tasks/google/cloud/tasks_v2beta2/proto/target_pb2.py +++ b/tasks/google/cloud/tasks_v2beta2/proto/target_pb2.py @@ -363,12 +363,12 @@ user ID. The task's tag can only be set when the [task is created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask]. The tag must be less than 500 characters. SDK compatibility: - Although the SDK allows tags to be either string or `bytes `__, only UTF-8 encoded - tags can be used in Cloud Tasks. If a tag isn't UTF-8 encoded, - the tag will be empty when the task is returned by Cloud - Tasks. + Although the SDK allows tags to be either string or `bytes `_, only UTF-8 encoded tags can be used in Cloud + Tasks. If a tag isn't UTF-8 encoded, the tag will be empty + when the task is returned by Cloud Tasks. """, # @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.PullMessage) )) @@ -392,7 +392,7 @@ Using [AppEngineHttpTarget][google.cloud.tasks.v2beta2.AppEngineHttpTarget] requires - ```appengine.applications.get`` `__ + ```appengine.applications.get`` `_ Google IAM permission for the project and the following scope: ``https://www.googleapis.com/auth/cloud-platform`` @@ -434,16 +434,16 @@ Using [AppEngineHttpRequest][google.cloud.tasks.v2beta2.AppEngineHttpRequest] requires - ```appengine.applications.get`` `__ + ```appengine.applications.get`` `_ Google IAM permission for the project and the following scope: ``https://www.googleapis.com/auth/cloud-platform`` The task will be delivered to the App Engine app which belongs to the same project as the queue. For more information, see `How Requests are - Routed `__ and - how routing is affected by `dispatch - files `__. + Routed `_ + and how routing is affected by `dispatch + files `_. The [AppEngineRouting][google.cloud.tasks.v2beta2.AppEngineRouting] used to construct the URL that the task is delivered to can be set at the @@ -476,12 +476,13 @@ The app's request handler for the task's target URL must be able to handle HTTP requests with this http\_method, otherwise the task attempt will fail with error code 405 (Method Not - Allowed). See `Writing a push task request handler - `__ and the + Allowed). See `Writing a push task request handler `_ and the documentation for the request handlers in the language your - app is written in e.g. `Python Request Handler - `__. + app is written in e.g. `Python Request Handler `_. app_engine_routing: Task-level setting for App Engine routing. If set, [app\_engi ne\_routing\_override][google.cloud.tasks.v2beta2.AppEngineHtt @@ -497,8 +498,8 @@ maximum length allowed is 2083 characters. headers: HTTP request headers. This map contains the header field - names and values. Headers can be set when the `task is created - `__. + names and values. Headers can be set when the [task is + created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask]. Repeated headers are not supported but a header value can contain commas. Cloud Tasks sets some headers to default values: - ``User-Agent``: By default, this header is @@ -511,18 +512,18 @@ default, the ``Content-Type`` header is set to ``"application/octet-stream"``. The default can be overridden by explicitly setting ``Content-Type`` to a particular - media type when the `task is created - `__. For - example, ``Content-Type`` can be set to + media type when the [task is + created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask]. + For example, ``Content-Type`` can be set to ``"application/json"``. - ``Content-Length``: This is computed by Cloud Tasks. This value is output only. It cannot be changed. The headers below cannot be set or overridden: - ``Host`` - ``X-Google-*`` - ``X-AppEngine-*`` In addition, Cloud Tasks sets some headers when the task is dispatched, such as headers containing - information about the task; see `request headers - `__. These headers are set + information about the task; see `request headers `_. These headers are set only when the task is dispatched, so they are not visible when the task is returned in a Cloud Tasks response. Although there is no specific limit for the maximum number of headers @@ -551,13 +552,13 @@ For more information about services, versions, and instances see `An Overview of App - Engine `__, + Engine `_, `Microservices Architecture on Google App - Engine `__, `App - Engine Standard request - routing `__, + Engine `_, + `App Engine Standard request + routing `_, and `App Engine Flex request - routing `__. + routing `_. Attributes: @@ -599,20 +600,22 @@ App instance. By default, the task is sent to an instance which is available when the task is attempted. Requests can only be sent to a specific instance if `manual scaling is used - in App Engine Standard `__. + in App Engine Standard + `_. App Engine Flex does not support instances. For more information, see `App Engine Standard request routing - `__ - and `App Engine Flex request routing - `__. + `_ and `App Engine Flex request routing + `_. host: Output only. The host that the task is sent to. For more information, see `How Requests are Routed - `__. - The host is constructed as: - ``host = - [application_domain_name]``\ ``| [service] + '.' + - [application_domain_name]``\ ``| [version] + '.' + + `_. The host is constructed as: - + ``host = [application_domain_name]``\ ``| [service] + '.' + + [application_domain_name]``\ ``| [version] + '.' + [application_domain_name]``\ ``| [version_dot_service]+ '.' + [application_domain_name]``\ ``| [instance] + '.' + [application_domain_name]``\ ``| [instance_dot_service] + diff --git a/tasks/google/cloud/tasks_v2beta2/proto/task_pb2.py b/tasks/google/cloud/tasks_v2beta2/proto/task_pb2.py index 294bf867a41d..67f5dd3d95de 100644 --- a/tasks/google/cloud/tasks_v2beta2/proto/task_pb2.py +++ b/tasks/google/cloud/tasks_v2beta2/proto/task_pb2.py @@ -275,18 +275,19 @@ ations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID`` - ``PROJECT_ID`` can contain letters ([A-Za-z]), numbers ([0-9]), hyphens (-), colons (:), or periods (.). For more - information, see `Identifying projects `__ - ``LOCATION_ID`` is the - canonical ID for the task's location. The list of available - locations can be obtained by calling [ListLocations][google - .cloud.location.Locations.ListLocations]. For more - information, see https://cloud.google.com/about/locations/. - - ``QUEUE_ID`` can contain letters ([A-Za-z]), numbers ([0-9]), - or hyphens (-). The maximum length is 100 characters. - - ``TASK_ID`` can contain only letters ([A-Za-z]), numbers - ([0-9]), hyphens (-), or underscores (\_). The maximum - length is 500 characters. + information, see `Identifying projects + `_ - ``LOCATION_ID`` + is the canonical ID for the task's location. The list of + available locations can be obtained by calling [ListLocatio + ns][google.cloud.location.Locations.ListLocations]. For + more information, see + https://cloud.google.com/about/locations/. - ``QUEUE_ID`` can + contain letters ([A-Za-z]), numbers ([0-9]), or hyphens + (-). The maximum length is 100 characters. - ``TASK_ID`` can + contain only letters ([A-Za-z]), numbers ([0-9]), hyphens + (-), or underscores (\_). The maximum length is 500 + characters. payload_type: Required. The task's payload is used by the task's target to process the task. A payload is valid only if it is compatible @@ -340,20 +341,20 @@ a response. attempt_response_count: Output only. The number of attempts which have received a - response. This field is not calculated for `pull tasks - `__. + response. This field is not calculated for [pull + tasks][google.cloud.tasks.v2beta2.PullMessage]. first_attempt_status: Output only. The status of the task's first attempt. Only [di spatch\_time][google.cloud.tasks.v2beta2.AttemptStatus.dispatc h\_time] will be set. The other [AttemptStatus][google.cloud.tasks.v2beta2.AttemptStatus] information is not retained by Cloud Tasks. This field is not - calculated for `pull tasks - `__. + calculated for [pull + tasks][google.cloud.tasks.v2beta2.PullMessage]. last_attempt_status: Output only. The status of the task's last attempt. This - field is not calculated for `pull tasks - `__. + field is not calculated for [pull + tasks][google.cloud.tasks.v2beta2.PullMessage]. """, # @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.TaskStatus) )) diff --git a/tasks/synth.py b/tasks/synth.py index d87a8f61dad6..1105101d1bf7 100644 --- a/tasks/synth.py +++ b/tasks/synth.py @@ -58,3 +58,33 @@ r'.. _Enable the Cloud Tasks API.: https://cloud.google.com/tasks', '.. _Enable the Cloud Tasks API.: https://console.cloud.google.com/apis/' 'library/cloudtasks.googleapis.com') + +# Fix unindentation of bullet list second line +s.replace( + 'google/cloud/tasks_v2beta2/gapic/cloud_tasks_client.py', + '( \* .*\n )([^\s*])', + '\g<1> \g<2>') + +s.replace( + 'google/cloud/tasks_v2beta2/gapic/cloud_tasks_client.py', + '(Google IAM .*?_) ', + '\g<1>_ ') + +s.replace( + 'google/cloud/tasks_v2beta2/gapic/cloud_tasks_client.py', + r'(Sample filter \\"app_engine_http_target: )\*\\".', + '\g<1>\\*\\".') + +s.replace("google/cloud/**/*.py", "`[.\s\n]+ `__", "") + +# Issues with Anonymous ('__') links. Change to named. +s.replace( + "google/cloud/tasks_v2beta2/proto/*.py", + ">`__", + ">`_") + +# Wrapped link fails due ot space in link +s.replace( + "google/cloud/tasks_v2beta2/proto/queue_pb2.py", + '(uests in queue.yaml/xml) <\n\s+', + '\g<1>\n <')