start_hook_base.py 417 B

123456789101112131415161718
  1. class RayOnSparkStartHook:
  2. def __init__(self, is_global):
  3. self.is_global = is_global
  4. def get_default_temp_root_dir(self):
  5. return "/tmp"
  6. def on_ray_dashboard_created(self, port):
  7. pass
  8. def on_cluster_created(self, ray_cluster_handler):
  9. pass
  10. def on_spark_job_created(self, job_group_id):
  11. pass
  12. def custom_environment_variables(self):
  13. return {}