Skip to content

Commit 9782bde

Browse files
Add test assertions for row_count and supports_append
1 parent 6067577 commit 9782bde

File tree

1 file changed

+27
-0
lines changed

1 file changed

+27
-0
lines changed

tests/integration/dataframe/test_dataframe.py

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -637,6 +637,9 @@ def test__append_table_data__append_request_success(
637637
client.append_table_data(
638638
table_id, AppendTableDataRequest(frame=frame, end_of_data=True)
639639
)
640+
metadata = client.get_table_metadata(table_id)
641+
assert metadata.row_count == 2
642+
assert metadata.supports_append is False
640643

641644
def test__append_table_data__append_request_with_end_of_data_argument_disallowed(
642645
self, client: DataFrameClient, create_table
@@ -656,20 +659,29 @@ def test__append_table_data__append_request_without_end_of_data_success(
656659
table_id = self._new_single_int_table(create_table)
657660
frame = DataFrame(columns=["a"], data=[["7"], ["8"]])
658661
client.append_table_data(table_id, AppendTableDataRequest(frame=frame))
662+
metadata = client.get_table_metadata(table_id)
663+
assert metadata.row_count == 2
664+
assert metadata.supports_append is True
659665

660666
def test__append_table_data__accepts_dataframe_model(
661667
self, client: DataFrameClient, create_table
662668
):
663669
table_id = self._new_single_int_table(create_table)
664670
frame = DataFrame(columns=["a"], data=[["1"], ["2"]])
665671
client.append_table_data(table_id, frame, end_of_data=True)
672+
metadata = client.get_table_metadata(table_id)
673+
assert metadata.row_count == 2
674+
assert metadata.supports_append is False
666675

667676
def test__append_table_data__dataframe_without_end_of_data_success(
668677
self, client: DataFrameClient, create_table
669678
):
670679
table_id = self._new_single_int_table(create_table)
671680
frame = DataFrame(columns=["a"], data=[["10"], ["11"]])
672681
client.append_table_data(table_id, frame)
682+
metadata = client.get_table_metadata(table_id)
683+
assert metadata.row_count == 2
684+
assert metadata.supports_append is True
673685

674686
def test__append_table_data__none_without_end_of_data_raises(
675687
self, client: DataFrameClient, create_table
@@ -696,6 +708,9 @@ def test__append_table_data__arrow_ingestion_success(
696708
table_id = self._new_single_int_table(create_table)
697709
batch = pa.record_batch([pa.array([10, 11, 12])], names=["a"])
698710
client.append_table_data(table_id, [batch], end_of_data=True)
711+
metadata = client.get_table_metadata(table_id)
712+
assert metadata.row_count == 3
713+
assert metadata.supports_append is False
699714
with pytest.raises(ApiException):
700715
client.append_table_data(table_id, None, end_of_data=True)
701716

@@ -706,6 +721,9 @@ def test__append_table_data__single_recordbatch_success(
706721
table_id = self._new_single_int_table(create_table)
707722
batch = pa.record_batch([pa.array([1, 2, 3])], names=["a"])
708723
client.append_table_data(table_id, batch, end_of_data=True)
724+
metadata = client.get_table_metadata(table_id)
725+
assert metadata.row_count == 3
726+
assert metadata.supports_append is False
709727
with pytest.raises(ApiException):
710728
client.append_table_data(table_id, None, end_of_data=True)
711729

@@ -716,8 +734,14 @@ def test__append_table_data__arrow_ingestion_with_end_of_data_query_param_false(
716734
table_id = self._new_single_int_table(create_table)
717735
batch1 = pa.record_batch([pa.array([4, 5, 6])], names=["a"])
718736
client.append_table_data(table_id, [batch1], end_of_data=False)
737+
metadata = client.get_table_metadata(table_id)
738+
assert metadata.row_count == 3
739+
assert metadata.supports_append is True
719740
batch2 = pa.record_batch([pa.array([7, 8])], names=["a"])
720741
client.append_table_data(table_id, [batch2], end_of_data=True)
742+
metadata = client.get_table_metadata(table_id)
743+
assert metadata.row_count == 5
744+
assert metadata.supports_append is False
721745

722746
def test__append_table_data__empty_iterator_requires_end_of_data(
723747
self, client: DataFrameClient, create_table
@@ -729,6 +753,9 @@ def test__append_table_data__empty_iterator_requires_end_of_data(
729753
):
730754
client.append_table_data(table_id, [])
731755
client.append_table_data(table_id, [], end_of_data=True)
756+
metadata = client.get_table_metadata(table_id)
757+
assert metadata.row_count == 0
758+
assert metadata.supports_append is False
732759

733760
def test__append_table_data__arrow_iterable_with_non_recordbatch_elements_raises(
734761
self, client: DataFrameClient, create_table

0 commit comments

Comments
 (0)