🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

google/cloud/dataproc_v1/services/autoscaling_policy_service/async_client.py

@@ -44,7 +44,7 @@
 
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 
 from google.cloud.dataproc_v1.services.autoscaling_policy_service import pagers
 from google.cloud.dataproc_v1.types import autoscaling_policies

google/cloud/dataproc_v1/services/autoscaling_policy_service/client.py

@@ -48,7 +48,7 @@
 
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 
 from google.cloud.dataproc_v1.services.autoscaling_policy_service import pagers
 from google.cloud.dataproc_v1.types import autoscaling_policies

google/cloud/dataproc_v1/services/autoscaling_policy_service/transports/base.py

@@ -24,7 +24,7 @@
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
 

google/cloud/dataproc_v1/services/autoscaling_policy_service/transports/grpc.py

@@ -22,7 +22,7 @@
 from google.auth.transport.grpc import SslCredentials  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
 import grpc  # type: ignore
 

google/cloud/dataproc_v1/services/autoscaling_policy_service/transports/grpc_asyncio.py

@@ -21,7 +21,7 @@
 from google.auth.transport.grpc import SslCredentials  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
 import grpc  # type: ignore
 from grpc.experimental import aio  # type: ignore

google/cloud/dataproc_v1/services/autoscaling_policy_service/transports/rest.py

@@ -28,7 +28,6 @@
 from google.auth.transport.requests import AuthorizedSession  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
 from google.protobuf import json_format
 import grpc  # type: ignore
 from requests import __version__ as requests_version
@@ -39,6 +38,7 @@
     OptionalRetry = Union[retries.Retry, object]  # type: ignore
 
 
+from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
 
 from google.cloud.dataproc_v1.types import autoscaling_policies

google/cloud/dataproc_v1/services/batch_controller/async_client.py

@@ -46,7 +46,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import timestamp_pb2  # type: ignore
 
 from google.cloud.dataproc_v1.services.batch_controller import pagers
@@ -528,6 +528,7 @@ async def sample_list_batches():
         Returns:
             google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesAsyncPager:
                 A list of batch workloads.
+
                 Iterating over this object will yield
                 results and resolve additional pages
                 automatically.

google/cloud/dataproc_v1/services/batch_controller/client.py

@@ -50,7 +50,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import timestamp_pb2  # type: ignore
 
 from google.cloud.dataproc_v1.services.batch_controller import pagers
@@ -777,6 +777,7 @@ def sample_list_batches():
         Returns:
             google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesPager:
                 A list of batch workloads.
+
                 Iterating over this object will yield
                 results and resolve additional pages
                 automatically.

google/cloud/dataproc_v1/services/batch_controller/transports/rest.py

@@ -34,7 +34,6 @@
 from google.auth.transport.requests import AuthorizedSession  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
 from google.protobuf import json_format
 import grpc  # type: ignore
 from requests import __version__ as requests_version

google/cloud/dataproc_v1/services/cluster_controller/async_client.py

@@ -46,7 +46,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
 from google.protobuf import field_mask_pb2  # type: ignore
 

google/cloud/dataproc_v1/services/cluster_controller/client.py

@@ -50,7 +50,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
 from google.protobuf import field_mask_pb2  # type: ignore
 

google/cloud/dataproc_v1/services/cluster_controller/transports/rest.py

@@ -34,7 +34,6 @@
 from google.auth.transport.requests import AuthorizedSession  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
 from google.protobuf import json_format
 import grpc  # type: ignore
 from requests import __version__ as requests_version

google/cloud/dataproc_v1/services/job_controller/async_client.py

@@ -46,7 +46,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 
 from google.cloud.dataproc_v1.services.job_controller import pagers
 from google.cloud.dataproc_v1.types import jobs
@@ -740,6 +740,7 @@ async def sample_list_jobs():
         Returns:
             google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsAsyncPager:
                 A list of jobs in a project.
+
                 Iterating over this object will yield
                 results and resolve additional pages
                 automatically.

google/cloud/dataproc_v1/services/job_controller/client.py

@@ -50,7 +50,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 
 from google.cloud.dataproc_v1.services.job_controller import pagers
 from google.cloud.dataproc_v1.types import jobs
@@ -918,6 +918,7 @@ def sample_list_jobs():
         Returns:
             google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsPager:
                 A list of jobs in a project.
+
                 Iterating over this object will yield
                 results and resolve additional pages
                 automatically.

google/cloud/dataproc_v1/services/job_controller/transports/rest.py

@@ -34,7 +34,6 @@
 from google.auth.transport.requests import AuthorizedSession  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
 from google.protobuf import json_format
 import grpc  # type: ignore
 from requests import __version__ as requests_version

google/cloud/dataproc_v1/services/node_group_controller/async_client.py

@@ -46,7 +46,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 
 from google.cloud.dataproc_v1.types import clusters, node_groups, operations
 

google/cloud/dataproc_v1/services/node_group_controller/client.py

@@ -50,7 +50,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 
 from google.cloud.dataproc_v1.types import clusters, node_groups, operations
 

google/cloud/dataproc_v1/services/node_group_controller/transports/rest.py

@@ -34,7 +34,6 @@
 from google.auth.transport.requests import AuthorizedSession  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
 from google.protobuf import json_format
 import grpc  # type: ignore
 from requests import __version__ as requests_version

google/cloud/dataproc_v1/services/workflow_template_service/async_client.py

@@ -46,7 +46,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import duration_pb2  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
 from google.protobuf import timestamp_pb2  # type: ignore
@@ -392,6 +392,7 @@ async def get_workflow_template(
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> workflow_templates.WorkflowTemplate:
         r"""Retrieves the latest workflow template.
+
         Can retrieve previously instantiated template by
         specifying optional version parameter.
 

google/cloud/dataproc_v1/services/workflow_template_service/client.py

@@ -50,7 +50,7 @@
 from google.api_core import operation_async  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
+from google.longrunning import operations_pb2  # type: ignore
 from google.protobuf import duration_pb2  # type: ignore
 from google.protobuf import empty_pb2  # type: ignore
 from google.protobuf import timestamp_pb2  # type: ignore
@@ -643,6 +643,7 @@ def get_workflow_template(
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> workflow_templates.WorkflowTemplate:
         r"""Retrieves the latest workflow template.
+
         Can retrieve previously instantiated template by
         specifying optional version parameter.
 

google/cloud/dataproc_v1/services/workflow_template_service/transports/grpc.py

@@ -287,6 +287,7 @@ def get_workflow_template(
         r"""Return a callable for the get workflow template method over gRPC.
 
         Retrieves the latest workflow template.
+
         Can retrieve previously instantiated template by
         specifying optional version parameter.
 

google/cloud/dataproc_v1/services/workflow_template_service/transports/grpc_asyncio.py

@@ -292,6 +292,7 @@ def get_workflow_template(
         r"""Return a callable for the get workflow template method over gRPC.
 
         Retrieves the latest workflow template.
+
         Can retrieve previously instantiated template by
         specifying optional version parameter.
 

google/cloud/dataproc_v1/services/workflow_template_service/transports/rest.py

@@ -34,7 +34,6 @@
 from google.auth.transport.requests import AuthorizedSession  # type: ignore
 from google.iam.v1 import iam_policy_pb2  # type: ignore
 from google.iam.v1 import policy_pb2  # type: ignore
-from google.longrunning import operations_pb2
 from google.protobuf import json_format
 import grpc  # type: ignore
 from requests import __version__ as requests_version

google/cloud/dataproc_v1/types/autoscaling_policies.py

@@ -353,6 +353,7 @@ class UpdateAutoscalingPolicyRequest(proto.Message):
 
 class DeleteAutoscalingPolicyRequest(proto.Message):
     r"""A request to delete an autoscaling policy.
+
     Autoscaling policies in use by one or more clusters will not be
     deleted.
 

google/cloud/dataproc_v1/types/clusters.py

@@ -873,6 +873,7 @@ class Preemptibility(proto.Enum):
                 instance group.
             NON_PREEMPTIBLE (1):
                 Instances are non-preemptible.
+
                 This option is allowed for all instance groups
                 and is the only valid value for Master and
                 Worker instance groups.
@@ -1401,6 +1402,7 @@ class Substate(proto.Enum):
                 The agent-reported status is out of date (may
                 occur if Dataproc loses communication with
                 Agent).
+
                 Applies to RUNNING state.
         """
         UNSPECIFIED = 0
@@ -1459,10 +1461,8 @@ class KerberosConfig(proto.Message):
     Attributes:
         enable_kerberos (bool):
             Optional. Flag to indicate whether to
-            Kerberize the cluster (default:
-
-            false). Set this field to true to enable
-            Kerberos on a cluster.
+            Kerberize the cluster (default: false). Set this
+            field to true to enable Kerberos on a cluster.
         root_principal_password_uri (str):
             Optional. The Cloud Storage URI of a KMS
             encrypted file containing the root principal

google/cloud/dataproc_v1/types/jobs.py

@@ -959,6 +959,7 @@ class Substate(proto.Enum):
                 The job substate is unknown.
             SUBMITTED (1):
                 The Job is submitted to the agent.
+
                 Applies to RUNNING state.
             QUEUED (2):
                 The Job has been received and is awaiting
@@ -973,6 +974,7 @@ class Substate(proto.Enum):
                 between the agent and Dataproc. If the agent
                 does not send a timely update, the job will
                 fail.
+
                 Applies to RUNNING state.
         """
         UNSPECIFIED = 0

google/cloud/dataproc_v1/types/workflow_templates.py

@@ -224,6 +224,7 @@ class ManagedCluster(proto.Message):
             Required. The cluster name prefix. A unique
             cluster name will be formed by appending a
             random suffix.
+
             The name must contain only lower-case letters
             (a-z), numbers (0-9), and hyphens (-). Must
             begin with a letter. Cannot begin or end with
@@ -271,6 +272,7 @@ class ClusterSelector(proto.Message):
             Optional. The zone where workflow process
             executes. This parameter does not affect the
             selection of the cluster.
+
             If unspecified, the zone of the first cluster
             matching the selector is used.
         cluster_labels (MutableMapping[str, str]):
@@ -899,6 +901,7 @@ class GetWorkflowTemplateRequest(proto.Message):
             Optional. The version of workflow template to
             retrieve. Only previously instantiated versions
             can be retrieved.
+
             If unspecified, retrieves the current version.
     """
 
@@ -935,6 +938,7 @@ class InstantiateWorkflowTemplateRequest(proto.Message):
             instantiate. If specified, the workflow will be
             instantiated only if the current version of the
             workflow template has the supplied version.
+
             This option cannot be used to instantiate a
             previous version of workflow template.
         request_id (str):
@@ -1110,6 +1114,7 @@ def raw_page(self):
 
 class DeleteWorkflowTemplateRequest(proto.Message):
     r"""A request to delete a workflow template.
+
     Currently started workflows will remain running.
 
     Attributes: