gigl.src.common.utils.DataprocClusterInitData#

class gigl.src.common.utils.spark_job_manager.DataprocClusterInitData(project: str, region: str, service_account: str, temp_assets_bucket: str, cluster_name: str, num_workers: int, machine_type: str, num_local_ssds: int, is_debug_mode: bool, debug_cluster_owner_alias: str | None = None, init_script_uri: gigl.common.types.uri.gcs_uri.GcsUri | None = None, labels: Dict[str, str] | None = None)#

Bases: object

Methods

__init__

__eq__(other)#

Return self==value.

__hash__ = None#
__init__(project: str, region: str, service_account: str, temp_assets_bucket: str, cluster_name: str, num_workers: int, machine_type: str, num_local_ssds: int, is_debug_mode: bool, debug_cluster_owner_alias: str | None = None, init_script_uri: GcsUri | None = None, labels: Dict[str, str] | None = None) None#
__repr__()#

Return repr(self).

__weakref__#

list of weak references to the object (if defined)