Skip to content

Commit

Permalink
Remove DeprecationWarning.
Browse files Browse the repository at this point in the history
  • Loading branch information
j-bennet committed Jul 13, 2023
1 parent 41170bb commit 0e5cd50
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 19 deletions.
2 changes: 0 additions & 2 deletions dask_deltatable/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
12 changes: 0 additions & 12 deletions dask_deltatable/core.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
from __future__ import annotations

import os
import warnings
from functools import partial
from typing import Any

Expand Down Expand Up @@ -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__
5 changes: 0 additions & 5 deletions tests/test_core.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 0e5cd50

Please sign in to comment.