Remove deprecated code

dask/__init__.py

@@ -2,7 +2,6 @@
 
 from . import config, datasets
 from .core import istask
-from .context import set_options
 from .local import get_sync as get
 
 try:

dask/array/tests/test_atop.py

@@ -8,13 +8,7 @@
 import dask
 import dask.array as da
 from dask.highlevelgraph import HighLevelGraph
-from dask.blockwise import (
-    Blockwise,
-    rewrite_blockwise,
-    optimize_blockwise,
-    index_subs,
-    blockwise,
-)
+from dask.blockwise import Blockwise, rewrite_blockwise, optimize_blockwise, index_subs
 from dask.array.utils import assert_eq
 from dask.array.numpy_compat import _numpy_116
 from dask.utils_test import inc, dec
@@ -552,38 +546,6 @@ def test_validate_top_inputs():
     assert "i" in str(info.value)
 
 
-def test_gh_4176():
-    with warnings.catch_warnings():
-        warnings.simplefilter("ignore")
-        from dask.sharedict import ShareDict
-
-    def foo(A):
-        return A[None, ...]
-
-    A = da.ones(shape=(10, 20, 4), chunks=(2, 5, 4))
-
-    name = "D"
-
-    dsk = blockwise(
-        foo,
-        name,
-        ("nsrc", "ntime", "nbl", "npol"),
-        A.name,
-        ("ntime", "nbl", "npol"),
-        new_axes={"nsrc": 1},
-        numblocks={a.name: a.numblocks for a in (A,)},
-    )
-
-    array_dsk = ShareDict()
-    array_dsk.update(dsk)
-    array_dsk.update(A.__dask_graph__())
-
-    chunks = ((1,),) + A.chunks
-
-    D = da.Array(array_dsk, name, chunks, dtype=A.dtype)
-    D.sum(axis=0).compute()
-
-
 def test_dont_merge_before_reductions():
     x = da.ones(10, chunks=(5,))
     y = da.blockwise(inc, "i", x, "i", dtype=x.dtype)

dask/context.py

@@ -13,18 +13,6 @@
 thread_state = threading.local()
 
 
-def set_options(*args, **kwargs):
-    """ Deprecated: see dask.config.set instead """
-    raise TypeError(
-        "The dask.set_options function has been deprecated.\n"
-        "Please use dask.config.set instead\n\n"
-        "  Before: with dask.set_options(foo='bar'):\n"
-        "              ...\n"
-        "  After:  with dask.config.set(foo='bar'):\n"
-        "              ..."
-    )
-
-
 def globalmethod(default=None, key=None, falsey=None):
     """ Allow function to be taken over by globals
 

dask/dataframe/core.py

@@ -1339,9 +1339,7 @@ def _get_binary_operator(cls, op, inv=False):
         else:
             return lambda self, other: elemwise(op, self, other)
 
-    def rolling(
-        self, window, min_periods=None, freq=None, center=False, win_type=None, axis=0
-    ):
+    def rolling(self, window, min_periods=None, center=False, win_type=None, axis=0):
         """Provides rolling transformations.
 
         Parameters
@@ -1370,10 +1368,6 @@ def rolling(
         Returns
         -------
         a Rolling object on which to call a method to compute a statistic
-
-        Notes
-        -----
-        The `freq` argument is not supported.
         """
         from dask.dataframe.rolling import Rolling
 
@@ -1391,7 +1385,6 @@ def rolling(
             self,
             window=window,
             min_periods=min_periods,
-            freq=freq,
             center=center,
             win_type=win_type,
             axis=axis,

dask/dataframe/rolling.py

@@ -264,19 +264,8 @@ class Rolling(object):
     """Provides rolling window calculations."""
 
     def __init__(
-        self,
-        obj,
-        window=None,
-        min_periods=None,
-        freq=None,
-        center=False,
-        win_type=None,
-        axis=0,
+        self, obj, window=None, min_periods=None, center=False, win_type=None, axis=0
     ):
-        if freq is not None:
-            msg = "The deprecated freq argument is not supported."
-            raise NotImplementedError(msg)
-
         self.obj = obj  # dataframe or series
         self.window = window
         self.min_periods = min_periods