Skip to content

Commit 9c8e3be

Browse files
loosen test
1 parent efd041c commit 9c8e3be

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

tests/system/small/session/test_read_gbq_query.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -36,9 +36,9 @@ def test_read_gbq_query_w_allow_large_results(session: bigframes.Session):
3636
allow_large_results=False,
3737
)
3838
assert df_false.shape == (1, 1)
39-
roots_false = df_false._get_block().expr.node.roots
40-
assert any(isinstance(node, nodes.ReadLocalNode) for node in roots_false)
41-
assert not any(isinstance(node, nodes.ReadTableNode) for node in roots_false)
39+
nodes_false = df_false._get_block().expr.node.unique_nodes()
40+
assert any(isinstance(node, nodes.ReadLocalNode) for node in nodes_false)
41+
assert not any(isinstance(node, nodes.ReadTableNode) for node in nodes_false)
4242

4343
# Large results allowed should wrap a table.
4444
df_true = session.read_gbq(
@@ -47,8 +47,8 @@ def test_read_gbq_query_w_allow_large_results(session: bigframes.Session):
4747
allow_large_results=True,
4848
)
4949
assert df_true.shape == (1, 1)
50-
roots_true = df_true._get_block().expr.node.roots
51-
assert any(isinstance(node, nodes.ReadTableNode) for node in roots_true)
50+
nodes_true = df_true._get_block().expr.node.unique_nodes()
51+
assert any(isinstance(node, nodes.ReadTableNode) for node in nodes_true)
5252

5353

5454
def test_read_gbq_query_w_columns(session: bigframes.Session):

0 commit comments

Comments
 (0)