fix dask example

Alexandra Belousov · Alexandra Belousov · commit 8dc881662f9a · 2025-03-04T13:17:13.000+02:00
diff --git a/examples/dask-preprocessing-and-training/dask_on_ray.py b/examples/dask-preprocessing-and-training/dask_on_ray.py
@@ -35,9 +35,9 @@ def read_taxi_df_dask(dataset_path, X_vars, y_vars):
 
     img = rh.Image("dask_img").pip_install(
         [
+            "dask[distributed]<2024.11.0",
+            "dask[dataframe]<2024.11.0",
             "dask-ml",
-            "dask[distributed]",
-            "dask[dataframe]",
             "boto3",
             "s3fs",
             "xgboost",
diff --git a/examples/dask-preprocessing-and-training/launch_lightgbm_dask_aws.py b/examples/dask-preprocessing-and-training/launch_lightgbm_dask_aws.py
@@ -6,12 +6,7 @@
     cluster_name = f"rh-new-{num_nodes}"
 
     img = rh.Image("dask-img").pip_install(
-        [
-            "dask[distributed,dataframe]",
-            "dask-ml",
-            "gcsfs",
-            "lightgbm",
-        ],
+        ["dask[distributed,dataframe]", "dask-ml", "gcsfs", "lightgbm", "s3fs"],
     )
 
     cluster = rh.compute(
