From 2b88ed65e3b0f8988c523a11fad63f9302ba5983 Mon Sep 17 00:00:00 2001 From: Will Jones Date: Tue, 10 Jan 2023 20:18:09 -0800 Subject: [PATCH] drop the _df --- python/deltalake/table.py | 2 +- python/tests/test_table_read.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/python/deltalake/table.py b/python/deltalake/table.py index 1c97fa5ce0..27002e81d5 100644 --- a/python/deltalake/table.py +++ b/python/deltalake/table.py @@ -441,7 +441,7 @@ def __stringify_partition_values( out.append((field, op, str_value)) return out - def get_add_actions_df(self, flatten: bool = False) -> pyarrow.RecordBatch: + def get_add_actions(self, flatten: bool = False) -> pyarrow.RecordBatch: """ Return a dataframe with all current add actions. diff --git a/python/tests/test_table_read.py b/python/tests/test_table_read.py index 277bd84d39..164a32c008 100644 --- a/python/tests/test_table_read.py +++ b/python/tests/test_table_read.py @@ -273,7 +273,7 @@ def test_history_partitioned_table_metadata(): def test_add_actions_table(flatten: bool): table_path = "../rust/tests/data/delta-0.8.0-partitioned" dt = DeltaTable(table_path) - actions_df = dt.get_add_actions_df(flatten) + actions_df = dt.get_add_actions(flatten) # RecordBatch doesn't have a sort_by method yet actions_df = pa.Table.from_batches([actions_df]).sort_by("path").to_batches()[0]