From 4f9b26d5cc21053fe12b1710f32e3879ced77b18 Mon Sep 17 00:00:00 2001
From: clarkzinzow <clarkzinzow@gmail.com>
Date: Tue, 20 Feb 2024 16:02:52 -0800
Subject: [PATCH] Remove redundant prefix.

---
 tests/io/delta_lake/test_table_read.py           |  6 +++---
 tests/io/delta_lake/test_table_read_pushdowns.py | 12 ++++++------
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/tests/io/delta_lake/test_table_read.py b/tests/io/delta_lake/test_table_read.py
index f5ee09f54c..9451b6b9e3 100644
--- a/tests/io/delta_lake/test_table_read.py
+++ b/tests/io/delta_lake/test_table_read.py
@@ -12,7 +12,7 @@
 
 
 @pytest.mark.integration()
-def test_daft_deltalake_read_basic(tmp_path):
+def test_deltalake_read_basic(tmp_path):
     pd_df = pd.DataFrame(
         {
             "a": [1, 2, 3],
@@ -28,7 +28,7 @@ def test_daft_deltalake_read_basic(tmp_path):
 
 
 @pytest.mark.integration()
-def test_daft_deltalake_read_full(local_deltalake_table):
+def test_deltalake_read_full(local_deltalake_table):
     path, dfs = local_deltalake_table
     df = daft.read_delta_lake(str(path))
     assert df.schema() == Schema.from_pyarrow_schema(deltalake.DeltaTable(path).schema().to_pyarrow())
@@ -36,7 +36,7 @@ def test_daft_deltalake_read_full(local_deltalake_table):
 
 
 @pytest.mark.integration()
-def test_daft_deltalake_read_show(local_deltalake_table):
+def test_deltalake_read_show(local_deltalake_table):
     path, _ = local_deltalake_table
     df = daft.read_delta_lake(str(path))
     df.show()
diff --git a/tests/io/delta_lake/test_table_read_pushdowns.py b/tests/io/delta_lake/test_table_read_pushdowns.py
index 7b41c4bd07..2df649caea 100644
--- a/tests/io/delta_lake/test_table_read_pushdowns.py
+++ b/tests/io/delta_lake/test_table_read_pushdowns.py
@@ -12,7 +12,7 @@
 
 
 @pytest.mark.integration()
-def test_daft_deltalake_read_predicate_pushdown_on_data(local_deltalake_table):
+def test_deltalake_read_predicate_pushdown_on_data(local_deltalake_table):
     path, dfs = local_deltalake_table
     df = daft.read_delta_lake(str(path))
     df = df.where(df["a"] == 2)
@@ -23,7 +23,7 @@ def test_daft_deltalake_read_predicate_pushdown_on_data(local_deltalake_table):
 
 
 @pytest.mark.integration()
-def test_daft_deltalake_read_predicate_pushdown_on_part(local_deltalake_table):
+def test_deltalake_read_predicate_pushdown_on_part(local_deltalake_table):
     path, dfs = local_deltalake_table
     df = daft.read_delta_lake(str(path))
     df = df.where(df["part_idx"] == 2)
@@ -34,7 +34,7 @@ def test_daft_deltalake_read_predicate_pushdown_on_part(local_deltalake_table):
 
 
 @pytest.mark.integration()
-def test_daft_deltalake_read_predicate_pushdown_on_part_non_eq(local_deltalake_table):
+def test_deltalake_read_predicate_pushdown_on_part_non_eq(local_deltalake_table):
     path, dfs = local_deltalake_table
     df = daft.read_delta_lake(str(path))
     df = df.where(df["part_idx"] < 3)
@@ -45,7 +45,7 @@ def test_daft_deltalake_read_predicate_pushdown_on_part_non_eq(local_deltalake_t
 
 
 @pytest.mark.integration()
-def test_daft_deltalake_read_predicate_pushdown_on_part_and_data(local_deltalake_table):
+def test_deltalake_read_predicate_pushdown_on_part_and_data(local_deltalake_table):
     path, dfs = local_deltalake_table
     df = daft.read_delta_lake(str(path))
     df = df.where((df["part_idx"] == 2) & (df["e"] == datetime.datetime(2024, 2, 11)))
@@ -59,7 +59,7 @@ def test_daft_deltalake_read_predicate_pushdown_on_part_and_data(local_deltalake
 
 
 @pytest.mark.integration()
-def test_daft_deltalake_read_predicate_pushdown_on_part_and_data_same_clause(local_deltalake_table):
+def test_deltalake_read_predicate_pushdown_on_part_and_data_same_clause(local_deltalake_table):
     path, dfs = local_deltalake_table
     df = daft.read_delta_lake(str(path))
     df = df.where(df["part_idx"] < df["a"])
@@ -71,7 +71,7 @@ def test_daft_deltalake_read_predicate_pushdown_on_part_and_data_same_clause(loc
 
 
 @pytest.mark.integration()
-def test_daft_deltalake_read_predicate_pushdown_on_part_empty(local_deltalake_table):
+def test_deltalake_read_predicate_pushdown_on_part_empty(local_deltalake_table):
     path, dfs = local_deltalake_table
     df = daft.read_delta_lake(str(path))
     # There should only be len(dfs) - 1 partitions; see local_deltalake_table fixture.