adam_core.ray_cluster module¶

adam_core.ray_cluster.initialize_use_ray(num_cpus: int | None = None, object_store_bytes: int | None = None, **kwargs) → bool[source]¶: Ensures we use existing local cluster, or starts new one with desired resources