Skip to content

Commit

Permalink
FIX-#6967: Remove read_pickle_distributed/to_pickle_distributed funct…
Browse files Browse the repository at this point in the history
…ions as deprecated (#7258)

Signed-off-by: Anatoly Myachev <[email protected]>
  • Loading branch information
anmyachev authored May 13, 2024
1 parent c349426 commit 9992b12
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 26 deletions.
8 changes: 0 additions & 8 deletions modin/experimental/pandas/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,6 @@
"""

from modin.pandas import * # noqa F401, F403
from modin.utils import func_from_deprecated_location

from .io import ( # noqa F401
read_csv_glob,
Expand All @@ -44,10 +43,3 @@
read_sql,
read_xml_glob,
)

read_pickle_distributed = func_from_deprecated_location(
"read_pickle_glob",
"modin.experimental.pandas.io",
"`modin.experimental.pandas.read_pickle_distributed` is deprecated and will be removed in a future version. "
+ "Please use `modin.experimental.pandas.to_pickle_glob` instead.",
)
16 changes: 0 additions & 16 deletions modin/pandas/accessor.py
Original file line number Diff line number Diff line change
Expand Up @@ -331,22 +331,6 @@ def to_pickle_glob(
storage_options=storage_options,
)

def to_pickle_distributed(
self,
filepath_or_buffer,
compression: CompressionOptions = "infer",
protocol: int = pickle.HIGHEST_PROTOCOL,
storage_options: StorageOptions = None,
) -> None: # noqa
warnings.warn(
"`DataFrame.modin.to_pickle_distributed` is deprecated and will be removed in a future version. "
+ "Please use `DataFrame.modin.to_pickle_glob` instead.",
category=FutureWarning,
)
return self.to_pickle_glob(
filepath_or_buffer, compression, protocol, storage_options
)

def to_parquet_glob(
self,
path,
Expand Down
4 changes: 2 additions & 2 deletions modin/tests/experimental/test_io_exp.py
Original file line number Diff line number Diff line change
Expand Up @@ -253,8 +253,8 @@ def _pandas_read_csv_glob(path, storage_options):
@pytest.mark.parametrize(
"filename", ["test_default_to_pickle.pkl", "test_to_pickle*.pkl"]
)
@pytest.mark.parametrize("read_func", ["read_pickle_glob", "read_pickle_distributed"])
@pytest.mark.parametrize("to_func", ["to_pickle_glob", "to_pickle_distributed"])
@pytest.mark.parametrize("read_func", ["read_pickle_glob"])
@pytest.mark.parametrize("to_func", ["to_pickle_glob"])
def test_distributed_pickling(
tmp_path, filename, compression, pathlike, read_func, to_func
):
Expand Down

0 comments on commit 9992b12

Please sign in to comment.