From da83bbd7642ae367c4fd812a2275a4e45e46102f Mon Sep 17 00:00:00 2001 From: Eric Liang Date: Fri, 4 Sep 2020 12:16:32 -0700 Subject: [PATCH] [1.0] Move dask scheduler from experimental to util (#10553) * move dask * fix dask --- doc/source/dask-on-ray.rst | 5 ++--- python/ray/tests/test_dask_scheduler.py | 2 +- python/ray/{experimental => util}/dask/__init__.py | 0 python/ray/{experimental => util}/dask/common.py | 0 python/ray/{experimental => util}/dask/scheduler.py | 0 5 files changed, 3 insertions(+), 4 deletions(-) rename python/ray/{experimental => util}/dask/__init__.py (100%) rename python/ray/{experimental => util}/dask/common.py (100%) rename python/ray/{experimental => util}/dask/scheduler.py (100%) diff --git a/doc/source/dask-on-ray.rst b/doc/source/dask-on-ray.rst index aa0be4cfb..7c5626543 100644 --- a/doc/source/dask-on-ray.rst +++ b/doc/source/dask-on-ray.rst @@ -1,8 +1,7 @@ Dask on Ray =========== -Ray offers an experimental scheduler backend for Dask. -With this plugin, you can use familiar Dask APIs such as Dask DataFrames, and the computation will be executed by the Ray system. +Ray offers a scheduler backend for Dask. With this plugin, you can use familiar Dask APIs such as Dask DataFrames, and the computation will be executed by the Ray system. The Ray plugin can be used with any Dask `.compute() `__ call. Note that for execution on a Ray cluster, you should *not* use the `Dask.distributed `__ client. @@ -12,7 +11,7 @@ Here's an example: .. code-block:: python import ray - from ray.experimental.dask import ray_dask_get + from ray.util.dask import ray_dask_get import dask.delayed from time import sleep diff --git a/python/ray/tests/test_dask_scheduler.py b/python/ray/tests/test_dask_scheduler.py index 9f55fa4ac..0321b77c9 100644 --- a/python/ray/tests/test_dask_scheduler.py +++ b/python/ray/tests/test_dask_scheduler.py @@ -2,7 +2,7 @@ import dask import pytest import ray -from ray.experimental.dask import ray_dask_get +from ray.util.dask import ray_dask_get def test_ray_dask_basic(ray_start_regular_shared): diff --git a/python/ray/experimental/dask/__init__.py b/python/ray/util/dask/__init__.py similarity index 100% rename from python/ray/experimental/dask/__init__.py rename to python/ray/util/dask/__init__.py diff --git a/python/ray/experimental/dask/common.py b/python/ray/util/dask/common.py similarity index 100% rename from python/ray/experimental/dask/common.py rename to python/ray/util/dask/common.py diff --git a/python/ray/experimental/dask/scheduler.py b/python/ray/util/dask/scheduler.py similarity index 100% rename from python/ray/experimental/dask/scheduler.py rename to python/ray/util/dask/scheduler.py