We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a3b9b75 commit 958935eCopy full SHA for 958935e
1 file changed
bigquery_storage/tests/system/test_system.py
@@ -89,15 +89,3 @@ def test_read_rows_to_dataframe(client, project_id):
89
assert frame.latitude.dtype.name == "float16"
90
assert frame.longitude.dtype.name == "float64"
91
assert frame["name"].str.startswith("Central Park").any()
92
-
93
94
-def test_split_read_stream(client, project_id, table_reference):
95
- session = client.create_read_session(
96
- table_reference, parent="projects/{}".format(project_id)
97
- )
98
99
- split = client.split_read_stream(session.streams[0])
100
101
- assert split.primary_stream is not None
102
- assert split.remainder_stream is not None
103
- assert split.primary_stream != split.remainder_stream
0 commit comments