Package Methods (5.16.0)

Version latest

• 5.16.0 (latest)
• 5.15.1
• 5.14.0
• 5.13.0
• 5.12.0
• 5.10.2
• 5.9.3
• 5.8.0
• 5.7.0
• 5.6.0
• 5.5.1
• 5.4.3
• 5.3.0
• 5.2.0
• 5.1.0
• 5.0.3
• 4.0.3
• 3.3.2
• 3.2.0
• 3.1.1
• 3.0.0
• 2.6.2
• 2.5.0
• 2.4.0
• 2.3.1
• 2.2.0
• 2.0.2
• 1.1.3
• 1.0.1
• 0.8.2
• 0.7.0
• 0.6.1
• 0.5.0

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 = 

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
) -> str

Returns a fully-qualified autoscaling_policy string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.autoscaling_policy_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.cancel_operation

cancel_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.cancel_operation

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_billing_account_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_folder_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_location_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_organization_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_project_path

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.AutoscalingPolicy

Creates new autoscaling policy.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.create_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]]] = ()
) -> None

Deletes an autoscaling policy.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.delete_autoscaling_policy

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.delete_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.from_service_account_json

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.AutoscalingPolicy

Retrieves autoscaling policy.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_autoscaling_policy

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_iam_policy

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.list_autoscaling_policies

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.list_operations

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_autoscaling_policy_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_project_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.set_iam_policy

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.test_iam_permissions

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.AutoscalingPolicy

Updates (replaces) autoscaling policy.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.update_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 = 

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
) -> str

Returns a fully-qualified autoscaling_policy string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.autoscaling_policy_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.cancel_operation

cancel_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.cancel_operation

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_billing_account_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_folder_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_location_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_organization_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_project_path

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.AutoscalingPolicy

Creates new autoscaling policy.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.create_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]]] = ()
) -> None

Deletes an autoscaling policy.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.delete_autoscaling_policy

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.delete_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.from_service_account_json

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.AutoscalingPolicy

Retrieves autoscaling policy.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_autoscaling_policy

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_iam_policy

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.list_autoscaling_policies

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.list_operations

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_autoscaling_policy_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_project_path

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.set_iam_policy

google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.test_iam_permissions

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.AutoscalingPolicy

Updates (replaces) autoscaling policy.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.update_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.

See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesAsyncPager

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 = 

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) -> str

Returns 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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts 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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_billing_account_path

google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns 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) -> str

Returns 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) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_organization_path

google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns 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.AsyncOperation

Creates 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.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]]] = ()
) -> None

Deletes 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[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes 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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.from_service_account_json

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.Batch

Gets 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[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets 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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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.ListBatchesAsyncPager

Lists 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[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists 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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_project_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) -> str

Returns 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[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets 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[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests 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 = 

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) -> str

Returns 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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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.Operation

Creates 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.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]]] = ()
) -> None

Deletes 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[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes 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.Batch

Gets 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[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets 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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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.ListBatchesPager

Lists 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[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists 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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_organization_path

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_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) -> str

Returns 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[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets 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[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests 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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts 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) -> str

Returns 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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_billing_account_path

google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns 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) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_location_path

google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_organization_path

google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_project_path

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.AsyncOperation

Creates 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) -> str

Returns 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.AsyncOperation

Deletes 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[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes 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.AsyncOperation

Gets 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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.from_service_account_json

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.Cluster

Gets 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[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets 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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_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.ListClustersAsyncPager

Lists 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[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists 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) -> str

Returns 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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_project_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_crypto_key_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_node_group_path

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) -> str

Returns 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[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets 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.AsyncOperation

Starts 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.AsyncOperation

Stops 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[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.test_iam_permissions

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.AsyncOperation

Updates 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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts 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) -> str

Returns 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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_billing_account_path

google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_folder_path

common_folder_path(folder: str) -> str

Returns 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) -> str

Returns 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) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_organization_path

google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_project_path

common_project_path(project: str) -> str

Returns 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.Operation

Creates 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) -> str

Returns 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.Operation

Deletes 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[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes 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.Operation

Gets 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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.from_service_account_json

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.Cluster

Gets 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[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets 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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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.ListClustersPager

Lists 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[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists 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) -> str

Returns 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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_project_path

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) -> str

Returns 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[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets 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.Operation

Starts 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.Operation

Stops 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[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests 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.Operation

Updates 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 = 

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.Job

Starts 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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts 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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_billing_account_path

google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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]]] = ()
) -> None

Deletes 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[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes 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[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets 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.Job

Gets 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.

See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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.ListJobsAsyncPager

Lists 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[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists 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.

See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_organization_path

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[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets 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.Job

Submits 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.AsyncOperation

Submits 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[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests 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.Job

Updates 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 = 

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.Job

Starts 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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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]]] = ()
) -> None

Deletes 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[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes 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[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets 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.Job

Gets 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.

See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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.ListJobsPager

Lists 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[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists 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.

See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_billing_account_path

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[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets 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.Job

Submits 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.Operation

Submits 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[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests 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.Job

Updates 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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.cancel_operation

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_billing_account_path

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_folder_path

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_location_path

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_organization_path

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_project_path

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.AsyncOperation

Creates a node group in a cluster.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.create_node_group

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.delete_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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.from_service_account_json

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_iam_policy

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_mtls_endpoint_and_cert_source

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.NodeGroup

Gets the resource representation for a node group in a cluster.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_node_group

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_transport_class

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.list_operations

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.node_group_path

node_group_path(project: str, region: str, cluster: str, node_group: str) -> str

Returns a fully-qualified node_group string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.node_group_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_project_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_node_group_path

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.AsyncOperation

Resizes a node group in a cluster.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.resize_node_group

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.set_iam_policy

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.test_iam_permissions

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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts 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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_billing_account_path

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_folder_path

common_folder_path(folder: str) -> str

Returns 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) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_location_path

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_organization_path

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_project_path

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.Operation

Creates 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[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes 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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.from_service_account_json

google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets 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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_mtls_endpoint_and_cert_source

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.NodeGroup

Gets 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[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists 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) -> str

Returns 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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_project_path

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.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_node_group_path

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.Operation

Resizes 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[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets 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[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.test_iam_permissions

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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts 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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_billing_account_path

google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns 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) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_location_path

google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_organization_path

google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_project_path

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.AsyncOperation

Create an interactive session asynchronously.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.create_session

google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes 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.AsyncOperation

Deletes 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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.from_service_account_json

google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets 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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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.Session

Gets 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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_transport_class

google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists 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.ListSessionsAsyncPager

Lists 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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_project_path

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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_session_template_path

google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.service_path

service_path(project: str, location: str, service: str) -> str

Returns 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) -> str

Returns 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) -> str

Returns a fully-qualified session_template string.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.session_template_path

google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets 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.AsyncOperation

Terminates 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[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.test_iam_permissions

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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts 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) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_billing_account_path

google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_folder_path

common_folder_path(folder: str) -> str

Returns 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) -> str

Returns 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) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_organization_path

google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_project_path

common_project_path(project: str) -> str

Returns 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.Operation

Create an interactive session asynchronously.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.create_session

google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes 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.Operation

Deletes 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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.from_service_account_json

google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets 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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets 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.Session

Gets 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[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists 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.ListSessionsPager

Lists 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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_project_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.

See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_session_template_path

google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.service_path

service_path(project: str, location: str, service: str) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets 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.Operation

Terminates 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[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests 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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.cancel_operation

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_billing_account_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_folder_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_location_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_organization_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_project_path

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.SessionTemplate

Create a session template synchronously.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.create_session_template

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.delete_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]]] = ()
) -> None

Deletes a session template.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.delete_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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.from_service_account_json

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_iam_policy

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_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.SessionTemplate

Gets the resource representation for a session template.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_transport_class

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.list_operations

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.list_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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_project_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_service_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_session_template_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.service_path

service_path(project: str, location: str, service: str) -> str

Returns a fully-qualified service string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.service_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.session_template_path

session_template_path(project: str, location: str, template: str) -> str

Returns a fully-qualified session_template string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.session_template_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.set_iam_policy

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.test_iam_permissions

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.SessionTemplate

Updates the session template synchronously.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.update_session_template

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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.cancel_operation

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_billing_account_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_folder_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_location_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_organization_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_project_path

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.SessionTemplate

Create a session template synchronously.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.create_session_template

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.delete_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]]] = ()
) -> None

Deletes a session template.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.delete_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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.from_service_account_json

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_iam_policy

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_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.SessionTemplate

Gets the resource representation for a session template.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_session_template

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.list_operations

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.list_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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_project_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_service_path

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.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_session_template_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.service_path

service_path(project: str, location: str, service: str) -> str

Returns a fully-qualified service string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.service_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.session_template_path

session_template_path(project: str, location: str, template: str) -> str

Returns a fully-qualified session_template string.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.session_template_path

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.set_iam_policy

google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.test_iam_permissions

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.SessionTemplate

Updates the session template synchronously.

See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.update_session_template

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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.cancel_operation

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_billing_account_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_folder_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_location_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_organization_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_project_path

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.WorkflowTemplate

Creates new workflow template.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.create_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) -> str

Returns a fully-qualified crypto_key string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.crypto_key_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.delete_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]]] = ()
) -> None

Deletes a workflow template.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.delete_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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.from_service_account_json

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_iam_policy

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_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.WorkflowTemplate

Retrieves the latest workflow template.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_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.AsyncOperation

Instantiates a template and begins execution.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.instantiate_inline_workflow_template

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.AsyncOperation

Instantiates a template and begins execution.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.instantiate_workflow_template

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.list_operations

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.list_workflow_templates

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.node_group_path

node_group_path(project: str, region: str, cluster: str, node_group: str) -> str

Returns a fully-qualified node_group string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.node_group_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_project_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_crypto_key_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_node_group_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_service_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_workflow_template_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.service_path

service_path(project: str, location: str, service: str) -> str

Returns a fully-qualified service string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.service_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.set_iam_policy

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.test_iam_permissions

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.WorkflowTemplate

Updates (replaces) workflow template.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.update_workflow_template

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.workflow_template_path

workflow_template_path(project: str, region: str, workflow_template: str) -> str

Returns a fully-qualified workflow_template string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.workflow_template_path

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 = 

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[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = 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]]] = ()
) -> None

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.cancel_operation

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_billing_account_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_folder_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_location_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_organization_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_project_path

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.WorkflowTemplate

Creates new workflow template.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.create_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) -> str

Returns a fully-qualified crypto_key string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.crypto_key_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = 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]]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.delete_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]]] = ()
) -> None

Deletes a workflow template.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.delete_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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.from_service_account_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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.from_service_account_json

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = 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.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_iam_policy

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_mtls_endpoint_and_cert_source

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = 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.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_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.WorkflowTemplate

Retrieves the latest workflow template.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_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.Operation

Instantiates a template and begins execution.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.instantiate_inline_workflow_template

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.Operation

Instantiates a template and begins execution.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.instantiate_workflow_template

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = 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.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.list_operations

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.list_workflow_templates

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.node_group_path

node_group_path(project: str, region: str, cluster: str, node_group: str) -> str

Returns a fully-qualified node_group string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.node_group_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_billing_account_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_folder_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_location_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_organization_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_project_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_crypto_key_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_node_group_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_service_path

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.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_workflow_template_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.service_path

service_path(project: str, location: str, service: str) -> str

Returns a fully-qualified service string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.service_path

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = 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.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.set_iam_policy

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = 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.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.test_iam_permissions

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.WorkflowTemplate

Updates (replaces) workflow template.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.update_workflow_template

google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.workflow_template_path

workflow_template_path(project: str, region: str, workflow_template: str) -> str

Returns a fully-qualified workflow_template string.

See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.workflow_template_path

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