![[Google Cloud Documentation]](https://www.gstatic.com/devrel-devsite/prod/vdc800838fb8be04a9a7685606311d18c65800504bccf261551968ac74bffd42e/clouddocs/images/lockup_full_color.svg){kind=link}
![[]](https://docs.cloud.google.com/_static/clouddocs/images/icons/categories/devops-color.svg){kind=link}
Summary of entries of Methods for dataproc.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient
AutoscalingPolicyServiceAsyncClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport,
],
]
] = "grpc_asyncio",
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the autoscaling policy service async client.
See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.autoscaling_policy_path
autoscaling_policy_path(
project: str, location: str, autoscaling_policy: str
) -> strReturns a fully-qualified autoscaling_policy string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.create_autoscaling_policy
create_autoscaling_policy(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.CreateAutoscalingPolicyRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
policy: typing.Optional[
google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicy
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyCreates new autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.delete_autoscaling_policy
delete_autoscaling_policy(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.DeleteAutoscalingPolicyRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes an autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_autoscaling_policy
get_autoscaling_policy(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.GetAutoscalingPolicyRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyRetrieves autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport
]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.list_autoscaling_policies
list_autoscaling_policies(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesAsyncPager
)Lists autoscaling policies in the project.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_autoscaling_policy_path
parse_autoscaling_policy_path(path: str) -> typing.Dict[str, str]Parses a autoscaling_policy path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.update_autoscaling_policy
update_autoscaling_policy(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.UpdateAutoscalingPolicyRequest,
dict,
]
] = None,
*,
policy: typing.Optional[
google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicy
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyUpdates (replaces) autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient
AutoscalingPolicyServiceClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport,
],
]
] = None,
client_options: typing.Optional[
typing.Union[google.api_core.client_options.ClientOptions, dict]
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the autoscaling policy service client.
See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.exit
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.autoscaling_policy_path
autoscaling_policy_path(
project: str, location: str, autoscaling_policy: str
) -> strReturns a fully-qualified autoscaling_policy string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.create_autoscaling_policy
create_autoscaling_policy(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.CreateAutoscalingPolicyRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
policy: typing.Optional[
google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicy
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyCreates new autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.delete_autoscaling_policy
delete_autoscaling_policy(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.DeleteAutoscalingPolicyRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes an autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_autoscaling_policy
get_autoscaling_policy(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.GetAutoscalingPolicyRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyRetrieves autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Deprecated.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.list_autoscaling_policies
list_autoscaling_policies(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesPager
)Lists autoscaling policies in the project.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_autoscaling_policy_path
parse_autoscaling_policy_path(path: str) -> typing.Dict[str, str]Parses a autoscaling_policy path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.update_autoscaling_policy
update_autoscaling_policy(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.autoscaling_policies.UpdateAutoscalingPolicyRequest,
dict,
]
] = None,
*,
policy: typing.Optional[
google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicy
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyUpdates (replaces) autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesAsyncPager
ListAutoscalingPoliciesAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[
google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesResponse
],
],
request: google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesRequest,
response: google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiates the pager.
google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesPager
ListAutoscalingPoliciesPager(
method: typing.Callable[
[...],
google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesResponse,
],
request: google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesRequest,
response: google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiate the pager.
See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesPager
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient
BatchControllerAsyncClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport,
],
]
] = "grpc_asyncio",
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the batch controller async client.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.batch_path
batch_path(project: str, location: str, batch: str) -> strReturns a fully-qualified batch string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.batch_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.cancel_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_folder_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_location_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_project_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.create_batch
create_batch(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.batches.CreateBatchRequest, dict]
] = None,
*,
parent: typing.Optional[str] = None,
batch: typing.Optional[google.cloud.dataproc_v1.types.batches.Batch] = None,
batch_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationCreates a batch workload that executes asynchronously.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.create_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.crypto_key_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.delete_batch
delete_batch(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.batches.DeleteBatchRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes the batch workload resource.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.delete_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.delete_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_batch
get_batch(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.batches.GetBatchRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.batches.BatchGets the batch workload resource representation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_iam_policy
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport
]Returns an appropriate transport class.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_transport_class
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.list_batches
list_batches(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.batches.ListBatchesRequest, dict]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesAsyncPagerLists batch workloads.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.list_batches
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.list_operations
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_batch_path
parse_batch_path(path: str) -> typing.Dict[str, str]Parses a batch path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_batch_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_crypto_key_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_service_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.service_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.set_iam_policy
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.test_iam_permissions
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient
BatchControllerClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport,
],
]
] = None,
client_options: typing.Optional[
typing.Union[google.api_core.client_options.ClientOptions, dict]
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the batch controller client.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.exit
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.batch_path
batch_path(project: str, location: str, batch: str) -> strReturns a fully-qualified batch string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.batch_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.cancel_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_billing_account_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_folder_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_location_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_organization_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_project_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.create_batch
create_batch(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.batches.CreateBatchRequest, dict]
] = None,
*,
parent: typing.Optional[str] = None,
batch: typing.Optional[google.cloud.dataproc_v1.types.batches.Batch] = None,
batch_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationCreates a batch workload that executes asynchronously.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.create_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.crypto_key_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.delete_batch
delete_batch(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.batches.DeleteBatchRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes the batch workload resource.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.delete_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.delete_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_file
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_info
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_json
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_batch
get_batch(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.batches.GetBatchRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.batches.BatchGets the batch workload resource representation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Deprecated.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.list_batches
list_batches(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.batches.ListBatchesRequest, dict]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesPagerLists batch workloads.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.list_batches
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.list_operations
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_batch_path
parse_batch_path(path: str) -> typing.Dict[str, str]Parses a batch path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_batch_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_folder_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_location_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_project_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_crypto_key_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_service_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.service_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.test_iam_permissions
google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesAsyncPager
ListBatchesAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[google.cloud.dataproc_v1.types.batches.ListBatchesResponse],
],
request: google.cloud.dataproc_v1.types.batches.ListBatchesRequest,
response: google.cloud.dataproc_v1.types.batches.ListBatchesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiates the pager.
See more: google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesAsyncPager
google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesPager
ListBatchesPager(
method: typing.Callable[
[...], google.cloud.dataproc_v1.types.batches.ListBatchesResponse
],
request: google.cloud.dataproc_v1.types.batches.ListBatchesRequest,
response: google.cloud.dataproc_v1.types.batches.ListBatchesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiate the pager.
See more: google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesPager
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient
ClusterControllerAsyncClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport,
],
]
] = "grpc_asyncio",
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the cluster controller async client.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.cancel_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.cluster_path
cluster_path(project: str, location: str, cluster: str) -> strReturns a fully-qualified cluster string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.cluster_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_folder_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.create_cluster
create_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.CreateClusterRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster: typing.Optional[google.cloud.dataproc_v1.types.clusters.Cluster] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationCreates a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.create_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.crypto_key_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.delete_cluster
delete_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.DeleteClusterRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster_name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationDeletes a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.delete_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.delete_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.diagnose_cluster
diagnose_cluster(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.clusters.DiagnoseClusterRequest, dict
]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster_name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationGets cluster diagnostic information.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.diagnose_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_cluster
get_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.GetClusterRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster_name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.clusters.ClusterGets the resource representation for a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_iam_policy
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport
]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.list_clusters
list_clusters(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.ListClustersRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
filter: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersAsyncPagerLists all regions/{region}/clusters in a project alphabetically.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.list_clusters
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.list_operations
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.node_group_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_cluster_path
parse_cluster_path(path: str) -> typing.Dict[str, str]Parses a cluster path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_cluster_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_service_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.service_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.set_iam_policy
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.start_cluster
start_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.StartClusterRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationStarts a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.start_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.stop_cluster
stop_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.StopClusterRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationStops a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.stop_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.update_cluster
update_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.UpdateClusterRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster_name: typing.Optional[str] = None,
cluster: typing.Optional[google.cloud.dataproc_v1.types.clusters.Cluster] = None,
update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationUpdates a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.update_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient
ClusterControllerClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport,
],
]
] = None,
client_options: typing.Optional[
typing.Union[google.api_core.client_options.ClientOptions, dict]
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the cluster controller client.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.exit
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.cancel_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.cluster_path
cluster_path(project: str, location: str, cluster: str) -> strReturns a fully-qualified cluster string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.cluster_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_folder_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_location_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_project_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.create_cluster
create_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.CreateClusterRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster: typing.Optional[google.cloud.dataproc_v1.types.clusters.Cluster] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationCreates a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.create_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.crypto_key_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.delete_cluster
delete_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.DeleteClusterRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster_name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationDeletes a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.delete_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.delete_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.diagnose_cluster
diagnose_cluster(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.clusters.DiagnoseClusterRequest, dict
]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster_name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationGets cluster diagnostic information.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.diagnose_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_cluster
get_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.GetClusterRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster_name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.clusters.ClusterGets the resource representation for a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Deprecated.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.list_clusters
list_clusters(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.ListClustersRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
filter: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersPagerLists all regions/{region}/clusters in a project alphabetically.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.list_clusters
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.list_operations
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.node_group_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_cluster_path
parse_cluster_path(path: str) -> typing.Dict[str, str]Parses a cluster path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_cluster_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_crypto_key_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_node_group_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_service_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.service_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.start_cluster
start_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.StartClusterRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationStarts a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.start_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.stop_cluster
stop_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.StopClusterRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationStops a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.stop_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.test_iam_permissions
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.update_cluster
update_cluster(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.clusters.UpdateClusterRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
cluster_name: typing.Optional[str] = None,
cluster: typing.Optional[google.cloud.dataproc_v1.types.clusters.Cluster] = None,
update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationUpdates a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.update_cluster
google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersAsyncPager
ListClustersAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[google.cloud.dataproc_v1.types.clusters.ListClustersResponse],
],
request: google.cloud.dataproc_v1.types.clusters.ListClustersRequest,
response: google.cloud.dataproc_v1.types.clusters.ListClustersResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiates the pager.
See more: google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersAsyncPager
google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersPager
ListClustersPager(
method: typing.Callable[
[...], google.cloud.dataproc_v1.types.clusters.ListClustersResponse
],
request: google.cloud.dataproc_v1.types.clusters.ListClustersRequest,
response: google.cloud.dataproc_v1.types.clusters.ListClustersResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiate the pager.
See more: google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersPager
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient
JobControllerAsyncClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport,
],
]
] = "grpc_asyncio",
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the job controller async client.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.cancel_job
cancel_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.CancelJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.jobs.JobStarts a job cancellation request.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.cancel_job
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.cancel_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_folder_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_location_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_organization_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_project_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.delete_job
delete_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.DeleteJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes the job from the project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.delete_job
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.delete_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_file
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_info
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_json
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_iam_policy
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_job
get_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.GetJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.jobs.JobGets the resource representation for a job in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_job
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport
]Returns an appropriate transport class.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_transport_class
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.list_jobs
list_jobs(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.ListJobsRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
filter: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsAsyncPagerLists regions/{region}/jobs in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.list_jobs
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.list_operations
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_folder_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_location_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_project_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.set_iam_policy
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.submit_job
submit_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.SubmitJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job: typing.Optional[google.cloud.dataproc_v1.types.jobs.Job] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.jobs.JobSubmits a job to a cluster.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.submit_job
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.submit_job_as_operation
submit_job_as_operation(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.SubmitJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job: typing.Optional[google.cloud.dataproc_v1.types.jobs.Job] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationSubmits job to a cluster.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.submit_job_as_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.test_iam_permissions
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.update_job
update_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.UpdateJobRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.jobs.JobUpdates a job in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.update_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient
JobControllerClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport,
],
]
] = None,
client_options: typing.Optional[
typing.Union[google.api_core.client_options.ClientOptions, dict]
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the job controller client.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.exit
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.cancel_job
cancel_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.CancelJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.jobs.JobStarts a job cancellation request.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.cancel_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.cancel_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_billing_account_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_folder_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_location_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_organization_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_project_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.delete_job
delete_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.DeleteJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes the job from the project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.delete_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.delete_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_file
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_info
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_json
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_job
get_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.GetJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.jobs.JobGets the resource representation for a job in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Deprecated.
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.list_jobs
list_jobs(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.ListJobsRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
filter: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsPagerLists regions/{region}/jobs in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.list_jobs
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.list_operations
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_folder_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_location_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_organization_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_project_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.submit_job
submit_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.SubmitJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job: typing.Optional[google.cloud.dataproc_v1.types.jobs.Job] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.jobs.JobSubmits a job to a cluster.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.submit_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.submit_job_as_operation
submit_job_as_operation(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.SubmitJobRequest, dict]
] = None,
*,
project_id: typing.Optional[str] = None,
region: typing.Optional[str] = None,
job: typing.Optional[google.cloud.dataproc_v1.types.jobs.Job] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationSubmits job to a cluster.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.submit_job_as_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.test_iam_permissions
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.update_job
update_job(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.jobs.UpdateJobRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.jobs.JobUpdates a job in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.update_job
google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsAsyncPager
ListJobsAsyncPager(
method: typing.Callable[
[...], typing.Awaitable[google.cloud.dataproc_v1.types.jobs.ListJobsResponse]
],
request: google.cloud.dataproc_v1.types.jobs.ListJobsRequest,
response: google.cloud.dataproc_v1.types.jobs.ListJobsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiates the pager.
See more: google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsAsyncPager
google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsPager
ListJobsPager(
method: typing.Callable[
[...], google.cloud.dataproc_v1.types.jobs.ListJobsResponse
],
request: google.cloud.dataproc_v1.types.jobs.ListJobsRequest,
response: google.cloud.dataproc_v1.types.jobs.ListJobsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiate the pager.
See more: google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsPager
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient
NodeGroupControllerAsyncClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport,
],
]
] = "grpc_asyncio",
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the node group controller async client.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.create_node_group
create_node_group(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.node_groups.CreateNodeGroupRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
node_group: typing.Optional[
google.cloud.dataproc_v1.types.clusters.NodeGroup
] = None,
node_group_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationCreates a node group in a cluster.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_node_group
get_node_group(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.node_groups.GetNodeGroupRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.clusters.NodeGroupGets the resource representation for a node group in a cluster.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport
]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.resize_node_group
resize_node_group(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.node_groups.ResizeNodeGroupRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
size: typing.Optional[int] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationResizes a node group in a cluster.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient
NodeGroupControllerClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport,
],
]
] = None,
client_options: typing.Optional[
typing.Union[google.api_core.client_options.ClientOptions, dict]
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the node group controller client.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.exit
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.cancel_operation
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_folder_path
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.create_node_group
create_node_group(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.node_groups.CreateNodeGroupRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
node_group: typing.Optional[
google.cloud.dataproc_v1.types.clusters.NodeGroup
] = None,
node_group_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationCreates a node group in a cluster.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.create_node_group
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.delete_operation
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Deprecated.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_node_group
get_node_group(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.node_groups.GetNodeGroupRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.clusters.NodeGroupGets the resource representation for a node group in a cluster.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_node_group
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_operation
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.list_operations
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.node_group_path
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.resize_node_group
resize_node_group(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.node_groups.ResizeNodeGroupRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
size: typing.Optional[int] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationResizes a node group in a cluster.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.resize_node_group
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient
SessionControllerAsyncClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport,
],
]
] = "grpc_asyncio",
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the session controller async client.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.cancel_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_folder_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.create_session
create_session(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.sessions.CreateSessionRequest, dict]
] = None,
*,
parent: typing.Optional[str] = None,
session: typing.Optional[google.cloud.dataproc_v1.types.sessions.Session] = None,
session_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationCreate an interactive session asynchronously.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.create_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.crypto_key_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.delete_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.delete_session
delete_session(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.sessions.DeleteSessionRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationDeletes the interactive session resource.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.delete_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_iam_policy
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_session
get_session(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.sessions.GetSessionRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.sessions.SessionGets the resource representation for an interactive session.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport
]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.list_operations
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.list_sessions
list_sessions(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.sessions.ListSessionsRequest, dict]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsAsyncPagerLists interactive sessions.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.list_sessions
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_service_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_session_path
parse_session_path(path: str) -> typing.Dict[str, str]Parses a session path into its component segments.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_session_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_session_template_path
parse_session_template_path(path: str) -> typing.Dict[str, str]Parses a session_template path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.service_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.session_path
session_path(project: str, location: str, session: str) -> strReturns a fully-qualified session string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.session_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.session_template_path
session_template_path(project: str, location: str, template: str) -> strReturns a fully-qualified session_template string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.set_iam_policy
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.terminate_session
terminate_session(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.sessions.TerminateSessionRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationTerminates the interactive session.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.terminate_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient
SessionControllerClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport,
],
]
] = None,
client_options: typing.Optional[
typing.Union[google.api_core.client_options.ClientOptions, dict]
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the session controller client.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.exit
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.cancel_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_folder_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_location_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_project_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.create_session
create_session(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.sessions.CreateSessionRequest, dict]
] = None,
*,
parent: typing.Optional[str] = None,
session: typing.Optional[google.cloud.dataproc_v1.types.sessions.Session] = None,
session_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationCreate an interactive session asynchronously.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.create_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.crypto_key_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.delete_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.delete_session
delete_session(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.sessions.DeleteSessionRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationDeletes the interactive session resource.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.delete_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Deprecated.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_session
get_session(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.sessions.GetSessionRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.sessions.SessionGets the resource representation for an interactive session.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.list_operations
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.list_sessions
list_sessions(
request: typing.Optional[
typing.Union[google.cloud.dataproc_v1.types.sessions.ListSessionsRequest, dict]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsPagerLists interactive sessions.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.list_sessions
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_crypto_key_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_service_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_session_path
parse_session_path(path: str) -> typing.Dict[str, str]Parses a session path into its component segments.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_session_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_session_template_path
parse_session_template_path(path: str) -> typing.Dict[str, str]Parses a session_template path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.service_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.session_path
session_path(project: str, location: str, session: str) -> strReturns a fully-qualified session string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.session_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.session_template_path
session_template_path(project: str, location: str, template: str) -> strReturns a fully-qualified session_template string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.session_template_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.terminate_session
terminate_session(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.sessions.TerminateSessionRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationTerminates the interactive session.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.terminate_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.test_iam_permissions
google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsAsyncPager
ListSessionsAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[google.cloud.dataproc_v1.types.sessions.ListSessionsResponse],
],
request: google.cloud.dataproc_v1.types.sessions.ListSessionsRequest,
response: google.cloud.dataproc_v1.types.sessions.ListSessionsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiates the pager.
See more: google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsAsyncPager
google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsPager
ListSessionsPager(
method: typing.Callable[
[...], google.cloud.dataproc_v1.types.sessions.ListSessionsResponse
],
request: google.cloud.dataproc_v1.types.sessions.ListSessionsRequest,
response: google.cloud.dataproc_v1.types.sessions.ListSessionsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiate the pager.
See more: google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsPager
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient
SessionTemplateControllerAsyncClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport,
],
]
] = "grpc_asyncio",
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the session template controller async client.
See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.create_session_template
create_session_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.CreateSessionTemplateRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
session_template: typing.Optional[
google.cloud.dataproc_v1.types.session_templates.SessionTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateCreate a session template synchronously.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.delete_session_template
delete_session_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.DeleteSessionTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a session template.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_session_template
get_session_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.GetSessionTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateGets the resource representation for a session template.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport
]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.list_session_templates
list_session_templates(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesAsyncPager
)Lists session templates.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_session_template_path
parse_session_template_path(path: str) -> typing.Dict[str, str]Parses a session_template path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.session_template_path
session_template_path(project: str, location: str, template: str) -> strReturns a fully-qualified session_template string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.update_session_template
update_session_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.UpdateSessionTemplateRequest,
dict,
]
] = None,
*,
session_template: typing.Optional[
google.cloud.dataproc_v1.types.session_templates.SessionTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateUpdates the session template synchronously.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient
SessionTemplateControllerClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport,
],
]
] = None,
client_options: typing.Optional[
typing.Union[google.api_core.client_options.ClientOptions, dict]
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the session template controller client.
See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.exit
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.create_session_template
create_session_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.CreateSessionTemplateRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
session_template: typing.Optional[
google.cloud.dataproc_v1.types.session_templates.SessionTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateCreate a session template synchronously.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.delete_session_template
delete_session_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.DeleteSessionTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a session template.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Deprecated.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_session_template
get_session_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.GetSessionTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateGets the resource representation for a session template.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.list_session_templates
list_session_templates(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesPager
)Lists session templates.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_session_template_path
parse_session_template_path(path: str) -> typing.Dict[str, str]Parses a session_template path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.session_template_path
session_template_path(project: str, location: str, template: str) -> strReturns a fully-qualified session_template string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.update_session_template
update_session_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.session_templates.UpdateSessionTemplateRequest,
dict,
]
] = None,
*,
session_template: typing.Optional[
google.cloud.dataproc_v1.types.session_templates.SessionTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateUpdates the session template synchronously.
google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesAsyncPager
ListSessionTemplatesAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[
google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesResponse
],
],
request: google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesRequest,
response: google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiates the pager.
See more: google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesAsyncPager
google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesPager
ListSessionTemplatesPager(
method: typing.Callable[
[...],
google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesResponse,
],
request: google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesRequest,
response: google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiate the pager.
See more: google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesPager
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient
WorkflowTemplateServiceAsyncClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport,
],
]
] = "grpc_asyncio",
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the workflow template service async client.
See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.create_workflow_template
create_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.CreateWorkflowTemplateRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
template: typing.Optional[
google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateCreates new workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.delete_workflow_template
delete_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.DeleteWorkflowTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport
]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_workflow_template
get_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.GetWorkflowTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateRetrieves the latest workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.instantiate_inline_workflow_template
instantiate_inline_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.InstantiateInlineWorkflowTemplateRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
template: typing.Optional[
google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationInstantiates a template and begins execution.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.instantiate_workflow_template
instantiate_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.InstantiateWorkflowTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
parameters: typing.Optional[typing.MutableMapping[str, str]] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperationInstantiates a template and begins execution.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.list_workflow_templates
list_workflow_templates(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesAsyncPager
)Lists workflows that match the specified filter in the request.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_workflow_template_path
parse_workflow_template_path(path: str) -> typing.Dict[str, str]Parses a workflow_template path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.update_workflow_template
update_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.UpdateWorkflowTemplateRequest,
dict,
]
] = None,
*,
template: typing.Optional[
google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateUpdates (replaces) workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.workflow_template_path
workflow_template_path(project: str, region: str, workflow_template: str) -> strReturns a fully-qualified workflow_template string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient
WorkflowTemplateServiceClient(
*,
credentials: typing.Optional[google.auth.credentials.Credentials] = None,
transport: typing.Optional[
typing.Union[
str,
google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport,
typing.Callable[
[...],
google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport,
],
]
] = None,
client_options: typing.Optional[
typing.Union[google.api_core.client_options.ClientOptions, dict]
] = None,
client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo
)Instantiates the workflow template service client.
See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.exit
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.cancel_operation
cancel_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.create_workflow_template
create_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.CreateWorkflowTemplateRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
template: typing.Optional[
google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateCreates new workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.delete_operation
delete_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.delete_workflow_template
delete_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.DeleteWorkflowTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> NoneDeletes a workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_iam_policy
get_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)Deprecated.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_operation
get_operation(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_workflow_template
get_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.GetWorkflowTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateRetrieves the latest workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.instantiate_inline_workflow_template
instantiate_inline_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.InstantiateInlineWorkflowTemplateRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
template: typing.Optional[
google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationInstantiates a template and begins execution.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.instantiate_workflow_template
instantiate_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.InstantiateWorkflowTemplateRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
parameters: typing.Optional[typing.MutableMapping[str, str]] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.OperationInstantiates a template and begins execution.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.list_operations
list_operations(
request: typing.Optional[
typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.list_workflow_templates
list_workflow_templates(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesPager
)Lists workflows that match the specified filter in the request.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_workflow_template_path
parse_workflow_template_path(path: str) -> typing.Dict[str, str]Parses a workflow_template path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.set_iam_policy
set_iam_policy(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.test_iam_permissions
test_iam_permissions(
request: typing.Optional[
typing.Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.update_workflow_template
update_workflow_template(
request: typing.Optional[
typing.Union[
google.cloud.dataproc_v1.types.workflow_templates.UpdateWorkflowTemplateRequest,
dict,
]
] = None,
*,
template: typing.Optional[
google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate
] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateUpdates (replaces) workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.workflow_template_path
workflow_template_path(project: str, region: str, workflow_template: str) -> strReturns a fully-qualified workflow_template string.
google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesAsyncPager
ListWorkflowTemplatesAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[
google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesResponse
],
],
request: google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesRequest,
response: google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiates the pager.
See more: google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesAsyncPager
google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesPager
ListWorkflowTemplatesPager(
method: typing.Callable[
[...],
google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesResponse,
],
request: google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesRequest,
response: google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)Instantiate the pager.
See more: google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesPager