gigl.src.common.utils.SparkJobManager

class gigl.src.common.utils.spark_job_manager.SparkJobManager(project: str, region: str, cluster_name: str)

Bases: object

Methods

__init__
create_dataproc_cluster
delete_cluster
get_sanitized_dataproc_cluster_name
submit_and_wait_scala_spark_job

__init__(project: str, region: str, cluster_name: str)

__weakref__

list of weak references to the object (if defined)