__init__.py 277 B

12345678910111213
  1. from ray.util.spark.cluster_init import (
  2. MAX_NUM_WORKER_NODES,
  3. setup_global_ray_cluster,
  4. setup_ray_cluster,
  5. shutdown_ray_cluster,
  6. )
  7. __all__ = [
  8. "setup_ray_cluster",
  9. "shutdown_ray_cluster",
  10. "MAX_NUM_WORKER_NODES",
  11. "setup_global_ray_cluster",
  12. ]