diff --git a/continuous_integration/environment-3.7.yaml b/continuous_integration/environment-3.7.yaml index 5ab9cd81608..925b1019b41 100644 --- a/continuous_integration/environment-3.7.yaml +++ b/continuous_integration/environment-3.7.yaml @@ -37,7 +37,6 @@ dependencies: - aiohttp - bokeh - httpretty - - chest - s3fs - cloudpickle - crick diff --git a/continuous_integration/environment-3.8-dev.yaml b/continuous_integration/environment-3.8-dev.yaml index cb0509a8cf8..a02ada391e2 100644 --- a/continuous_integration/environment-3.8-dev.yaml +++ b/continuous_integration/environment-3.8-dev.yaml @@ -38,7 +38,6 @@ dependencies: - aiohttp - bokeh - httpretty - - chest - cloudpickle - crick - cytoolz diff --git a/continuous_integration/environment-3.8.yaml b/continuous_integration/environment-3.8.yaml index f91fc89249d..b170c2d895c 100644 --- a/continuous_integration/environment-3.8.yaml +++ b/continuous_integration/environment-3.8.yaml @@ -37,7 +37,6 @@ dependencies: - bokeh - httpretty - aiohttp - - chest - s3fs - cloudpickle - crick diff --git a/continuous_integration/environment-3.9.yaml b/continuous_integration/environment-3.9.yaml index 0b787ee8de6..e79ac3ed689 100644 --- a/continuous_integration/environment-3.9.yaml +++ b/continuous_integration/environment-3.9.yaml @@ -38,7 +38,6 @@ dependencies: - bokeh - httpretty - aiohttp - - chest - s3fs - cloudpickle - crick diff --git a/dask/dataframe/core.py b/dask/dataframe/core.py index 1a040a10380..8af631f6998 100644 --- a/dask/dataframe/core.py +++ b/dask/dataframe/core.py @@ -18,11 +18,6 @@ from pandas.util import cache_readonly from tlz import first, merge, partition_all, remove, unique -try: - from chest import Chest as Cache -except ImportError: - Cache = dict - from .. import array as da from .. import core, threaded from ..array.core import Array, normalize_arg diff --git a/dask/local.py b/dask/local.py index b407bf060f4..aba12512ea1 100644 --- a/dask/local.py +++ b/dask/local.py @@ -134,9 +134,6 @@ def queue_get(q): return q.get() -DEBUG = False - - def start_state_from_dask(dsk, cache=None, sortkey=None): """Start state from a dask @@ -274,13 +271,6 @@ def finish_task( s = state["waiting_data"][dep] s.remove(key) if not s and dep not in results: - if DEBUG: - from chest.core import nbytes - - print( - "Key: %s\tDep: %s\t NBytes: %.2f\t Release" - % (key, dep, sum(map(nbytes, state["cache"].values()) / 1e6)) - ) release_data(dep, state, delete=delete) elif delete and dep not in results: release_data(dep, state, delete=delete) diff --git a/dask/tests/test_local.py b/dask/tests/test_local.py index 1776d9f773a..60c90e4dae0 100644 --- a/dask/tests/test_local.py +++ b/dask/tests/test_local.py @@ -97,11 +97,7 @@ def test_get_sync_num_workers(self): def test_cache_options(): - try: - from chest import Chest - except ImportError: - return - cache = Chest() + cache = {} def inc2(x): assert "y" in cache