o c²“isã@sÊddlZddlmZeejƒedƒkr eejƒedƒkr edƒ‚ddlmZmZmZm Z ddl m Z m Z m Z mZdd lmZejZd d „Zeje_ejjjZd d „Zeje_dd„Zeeeƒgd¢ZdS)éN)ÚVersionÚ0z 2024.11.0z\Dask on Ray requires Dask version 2024.11.0 or later. Please upgrade your Dask installation.é)Ú ray_dask_getÚray_dask_get_syncÚenable_dask_on_rayÚdisable_dask_on_ray)ÚRayDaskCallbackÚlocal_ray_callbacksÚunpack_ray_callbacksÚProgressBarCallback)Údataframe_optimizecOsd|d<t|i|¤ŽS©NTÚ ray_persist)Ú dask_persist)ÚargsÚkwargs©rúJ/home/ubuntu/.local/lib/python3.10/site-packages/ray/util/dask/__init__.pyÚray_dask_persistsrcKsd|d<t|fi|¤ŽSr)Údask_persist_mixin)ÚselfrrrrÚray_dask_persist_mixin)srcCs|t_|tjj_dS)N)ÚdaskÚpersistÚbaseÚDaskMethodsMixin)rrrrrÚ patch_dask4sr) rrrrrr r r r r )rÚpackaging.versionrÚ __version__Ú ImportErrorÚ schedulerrrrrÚ callbacksr r r r Ú optimizationsr rrrÚ__doc__rrrrrÚ__all__rrrrÚs( ÿÿ