Skip to content

Commit 6a2ae4c

Browse files
fix test and import
1 parent 5d9e208 commit 6a2ae4c

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

tests/system/small/test_polars_execution.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import pytest
1515

1616
import bigframes
17-
from tests.system.utils import assert_pandas_df_equal
17+
from bigframes.testing.utils import assert_pandas_df_equal
1818

1919
polars = pytest.importorskip("polars", reason="polars is required for this test")
2020

@@ -53,7 +53,8 @@ def test_polar_execution_sorted_filtered(session_w_polars, scalars_pandas_df_ind
5353
.to_pandas()
5454
)
5555

56-
assert session_w_polars._metrics.execution_count == execution_count_before
56+
# Filter and isnull not supported by polar engine yet, so falls back to bq execution
57+
assert session_w_polars._metrics.execution_count == (execution_count_before + 1)
5758
assert_pandas_df_equal(bf_result, pd_result)
5859

5960

@@ -70,5 +71,6 @@ def test_polar_execution_unsupported_sql_fallback(
7071
bf_df["str_len_col"] = bf_df.string_col.str.len()
7172
bf_result = bf_df.to_pandas()
7273

74+
# str len not supported by polar engine yet, so falls back to bq execution
7375
assert session_w_polars._metrics.execution_count == (execution_count_before + 1)
7476
assert_pandas_df_equal(bf_result, pd_result)

0 commit comments

Comments
 (0)