Skip to content

Commit 9cdd0dc

Browse files
committed
test: enhance test_register_filtered_dataframe with additional assertions for DataFrame results
1 parent 8578713 commit 9cdd0dc

File tree

1 file changed

+12
-2
lines changed

1 file changed

+12
-2
lines changed

python/tests/test_view.py

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,13 +21,23 @@ def test_register_filtered_dataframe():
2121

2222
df_view = ctx.sql("SELECT * FROM view1")
2323

24-
results = df_view.collect()
24+
filtered_results = df_view.collect()
2525

26-
result_dicts = [batch.to_pydict() for batch in results]
26+
result_dicts = [batch.to_pydict() for batch in filtered_results]
2727

2828
expected_results = [
2929
{"a": [3, 4, 5], "b": [30, 40, 50]}
3030
]
3131

3232
assert result_dicts == expected_results
3333

34+
df_results = df.collect()
35+
36+
df_result_dicts = [batch.to_pydict() for batch in df_results]
37+
38+
expected_df_results = [
39+
{"a": [1, 2, 3, 4, 5], "b": [10, 20, 30, 40, 50]}
40+
]
41+
42+
assert df_result_dicts == expected_df_results
43+

0 commit comments

Comments
 (0)