diff --git a/dask_deltatable/__init__.py b/dask_deltatable/__init__.py index a4422d9..5aa7763 100644 --- a/dask_deltatable/__init__.py +++ b/dask_deltatable/__init__.py @@ -3,9 +3,7 @@ __all__ = [ "read_deltalake", "to_deltalake", - "read_delta_table", ] -from .core import read_delta_table as read_delta_table from .core import read_deltalake as read_deltalake from .write import to_deltalake as to_deltalake diff --git a/dask_deltatable/core.py b/dask_deltatable/core.py index f10be01..0cb0d74 100644 --- a/dask_deltatable/core.py +++ b/dask_deltatable/core.py @@ -1,7 +1,6 @@ from __future__ import annotations import os -import warnings from functools import partial from typing import Any @@ -246,14 +245,3 @@ def read_deltalake( ) resultdf = dtw.read_delta_table(columns=columns, **kwargs) return resultdf - - -def read_delta_table(*args, **kwargs): - warnings.warn( - "`read_delta_table` was renamed, use `read_deltalake` instead", - category=DeprecationWarning, - ) - return read_deltalake(*args, **kwargs) - - -read_delta_table.__doc__ = read_deltalake.__doc__ diff --git a/tests/test_core.py b/tests/test_core.py index e925943..89e9eb5 100644 --- a/tests/test_core.py +++ b/tests/test_core.py @@ -135,11 +135,6 @@ def test_empty(empty_table1, empty_table2): _ = ddt.read_deltalake(empty_table2) -def test_read_delta_table_warns(simple_table): - with pytest.warns(DeprecationWarning, match="`read_delta_table` was renamed"): - ddt.read_delta_table(simple_table) - - def test_checkpoint(checkpoint_table): df = ddt.read_deltalake(checkpoint_table, checkpoint=0, version=4) assert df.compute().shape[0] == 25