Copy lintified proto files (via synth). (#7471)

Author: yoshi-automation

google/cloud/tasks_v2beta2/gapic/enums.py

@@ -240,10 +240,10 @@ class View(enum.IntEnum):
           BASIC (int): The basic view omits fields which can be large or can contain sensitive
           data.
 
-          This view does not include the (``payload in AppEngineHttpRequest`` and
-          ``payload in PullMessage``). These payloads are desirable to return only
-          when needed, because they can be large and because of the sensitivity of
-          the data that you choose to store in it.
+          This view does not include the (``payload in  AppEngineHttpRequest`` and
+          ``payload in  PullMessage``). These payloads are desirable to return
+          only when needed, because they can be large and because of the
+          sensitivity of the data that you choose to store in it.
           FULL (int): All information is returned.
 
           Authorization for ``FULL`` requires ``cloudtasks.tasks.fullView``

google/cloud/tasks_v2beta2/proto/cloudtasks.proto

@@ -153,14 +153,15 @@ def CreateQueue(self, request, context):
         """Creates a queue.
 
     Queues created with this method allow tasks to live for a maximum of 31
-    days. After a task is 31 days old, the task will be deleted regardless of whether
-    it was dispatched or not.
+    days. After a task is 31 days old, the task will be deleted regardless of
+    whether it was dispatched or not.
 
     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](https://cloud.google.com/tasks/docs/queue-yaml)
-    before using this method.
+    [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)
         context.set_details("Method not implemented!")
@@ -173,14 +174,15 @@ def UpdateQueue(self, request, context):
     the queue if it does exist.
 
     Queues created with this method allow tasks to live for a maximum of 31
-    days. After a task is 31 days old, the task will be deleted regardless of whether
-    it was dispatched or not.
+    days. After a task is 31 days old, the task will be deleted regardless of
+    whether it was dispatched or not.
 
     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](https://cloud.google.com/tasks/docs/queue-yaml)
-    before using this method.
+    [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)
         context.set_details("Method not implemented!")
@@ -197,8 +199,9 @@ 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](https://cloud.google.com/tasks/docs/queue-yaml)
-    before using this method.
+    [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)
         context.set_details("Method not implemented!")
@@ -221,9 +224,10 @@ def PauseQueue(self, request, context):
 
     If a queue is paused then the system will stop dispatching tasks
     until the queue is resumed via
-    [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can still be added
-    when the queue is paused. A queue is paused if its
-    [state][google.cloud.tasks.v2beta2.Queue.state] is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+    [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can
+    still be added when the queue is paused. A queue is paused if its
+    [state][google.cloud.tasks.v2beta2.Queue.state] is
+    [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
     """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details("Method not implemented!")
@@ -234,23 +238,26 @@ def ResumeQueue(self, request, context):
 
     This method resumes a queue after it has been
     [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or
-    [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a queue is stored
-    in the queue's [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method it
-    will be set to [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING].
+    [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a
+    queue is stored in the queue's
+    [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method
+    it will be set to
+    [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING].
 
     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](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling).
+    [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!")
         raise NotImplementedError("Method not implemented!")
 
     def GetIamPolicy(self, request, context):
-        """Gets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue].
-    Returns an empty policy if the resource exists and does not have a policy
-    set.
+        """Gets the access control policy for a
+    [Queue][google.cloud.tasks.v2beta2.Queue]. Returns an empty policy if the
+    resource exists and does not have a policy set.
 
     Authorization requires the following
     [Google IAM](https://cloud.google.com/iam) permission on the specified
@@ -263,8 +270,8 @@ def GetIamPolicy(self, request, context):
         raise NotImplementedError("Method not implemented!")
 
     def SetIamPolicy(self, request, context):
-        """Sets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing
-    policy.
+        """Sets the access control policy for a
+    [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing policy.
 
     Note: The Cloud Console does not check queue-level IAM permissions yet.
     Project-level permissions are required to use the Cloud Console.
@@ -280,9 +287,10 @@ def SetIamPolicy(self, request, context):
         raise NotImplementedError("Method not implemented!")
 
     def TestIamPermissions(self, request, context):
-        """Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta2.Queue].
-    If the resource does not exist, this will return an empty set of
-    permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
+        """Returns permissions that a caller has on a
+    [Queue][google.cloud.tasks.v2beta2.Queue]. If the resource does not exist,
+    this will return an empty set of permissions, not a
+    [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
 
     Note: This operation is designed to be used for building permission-aware
     UIs and command-line tools, not for authorization checking. This operation
@@ -295,10 +303,10 @@ def TestIamPermissions(self, request, context):
     def ListTasks(self, request, context):
         """Lists the tasks in a queue.
 
-    By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] view is retrieved
-    due to performance considerations;
-    [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] controls the
-    subset of information which is returned.
+    By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC]
+    view is retrieved 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.
@@ -319,9 +327,11 @@ 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
+    * 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.
+    * 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!")
@@ -344,18 +354,19 @@ def LeaseTasks(self, request, context):
 
     This method is invoked by the worker to obtain a lease. The
     worker must acknowledge the task via
-    [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] after they have
-    performed the work associated with the task.
-
-    The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended to store data that
-    the worker needs to perform the work associated with the task. To
-    return the payloads in the [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set
-    [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] to
-    [FULL][google.cloud.tasks.v2beta2.Task.View.FULL].
-
-    A maximum of 10 qps of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]
-    requests are allowed per
-    queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+    [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask]
+    after they have performed the work associated with the task.
+
+    The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended
+    to store data that the worker needs to perform the work associated with the
+    task. To return the payloads in the
+    [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set
+    [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view]
+    to [FULL][google.cloud.tasks.v2beta2.Task.View.FULL].
+
+    A maximum of 10 qps of
+    [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] requests are
+    allowed per queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
     is returned when this limit is
     exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
     is also returned when
@@ -370,12 +381,13 @@ def AcknowledgeTask(self, request, context):
         """Acknowledges a pull task.
 
     The worker, that is, the entity that
-    [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must call this method
-    to indicate that the work associated with the task has finished.
+    [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must
+    call this method to indicate that the work associated with the task has
+    finished.
 
     The worker must acknowledge a task within the
-    [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] or the lease
-    will expire and the task will become available to be leased
+    [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration]
+    or the lease will expire and the task will become available to be leased
     again. After the task is acknowledged, it will not be returned
     by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks],
     [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or
@@ -390,7 +402,8 @@ def RenewLease(self, request, context):
 
     The worker can use this method to extend the lease by a new
     duration, starting from now. The new task lease will be
-    returned in the task's [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time].
+    returned in the task's
+    [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time].
     """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details("Method not implemented!")
@@ -400,9 +413,9 @@ def CancelLease(self, request, context):
         """Cancel a pull task's lease.
 
     The worker can use this method to cancel a task's lease by
-    setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] to now. This will
-    make the task available to be leased to the next caller of
-    [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks].
+    setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time]
+    to now. This will make the task available to be leased to the next caller
+    of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks].
     """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details("Method not implemented!")
@@ -412,30 +425,33 @@ def RunTask(self, request, context):
         """Forces a task to run now.
 
     When this method is called, Cloud Tasks will dispatch the task, even if
-    the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or
-    is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+    the task is already running, the queue has reached its
+    [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or is
+    [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
 
     This command is meant to be used for manual debugging. For
-    example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be used to retry a failed
-    task after a fix has been made or to manually force a task to be
-    dispatched now.
+    example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be
+    used to retry a failed task after a fix has been made or to manually force
+    a task to be dispatched now.
 
     The dispatched task is returned. That is, the task that is returned
-    contains the [status][google.cloud.tasks.v2beta2.Task.status] after the task is dispatched but
-    before the task is received by its target.
+    contains the [status][google.cloud.tasks.v2beta2.Task.status] after the
+    task is dispatched but before the task is received by its target.
 
     If Cloud Tasks receives a successful response from the task's
     target, then the task will be deleted; otherwise the task's
-    [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be reset to the time that
-    [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus the retry delay specified
-    in the queue's [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig].
+    [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be
+    reset to the time that
+    [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus
+    the retry delay specified in the queue's
+    [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig].
 
     [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns
     [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a
     task that has already succeeded or permanently failed.
 
-    [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called on a
-    [pull task][google.cloud.tasks.v2beta2.PullMessage].
+    [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called
+    on a [pull task][google.cloud.tasks.v2beta2.PullMessage].
     """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details("Method not implemented!")