diff --git a/tests/system/test_data_api.py b/tests/system/test_data_api.py index c833b0a77..7c02e3395 100644 --- a/tests/system/test_data_api.py +++ b/tests/system/test_data_api.py @@ -399,7 +399,7 @@ def test_mutations_batcher_threading(data_table, rows_to_delete): def callback(results): all_results.extend(results) - assert results <= max_elements_per_batch + assert len(results) <= max_elements_per_batch # override flow control max elements with mock.patch(