| 123456789101112131415161718 |
- class RayOnSparkStartHook:
- def __init__(self, is_global):
- self.is_global = is_global
- def get_default_temp_root_dir(self):
- return "/tmp"
- def on_ray_dashboard_created(self, port):
- pass
- def on_cluster_created(self, ray_cluster_handler):
- pass
- def on_spark_job_created(self, job_group_id):
- pass
- def custom_environment_variables(self):
- return {}
|