Remove chest (#8279)

dask · Oct 21, 2021 · a544670 · a544670
1 parent 6dbf095
commit a544670
Show file tree

Hide file tree

Showing 7 changed files with 1 addition and 24 deletions.
diff --git 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
@@ -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
@@ -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
@@ -38,7 +38,6 @@ dependencies:
   - bokeh
   - httpretty
   - aiohttp
-  - chest
   - s3fs
   - cloudpickle
   - crick

diff --git 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
@@ -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
@@ -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