()
| 1214 | |
| 1215 | |
| 1216 | def test_flight_do_get_dicts(): |
| 1217 | table = simple_dicts_table() |
| 1218 | |
| 1219 | with ConstantFlightServer() as server, \ |
| 1220 | flight.connect(('localhost', server.port)) as client: |
| 1221 | reader = client.do_get(flight.Ticket(b'dicts')) |
| 1222 | assert reader.stats.num_messages == 1 |
| 1223 | data = reader.read_all() |
| 1224 | assert data.equals(table) |
| 1225 | assert reader.stats == ReadStats( |
| 1226 | num_messages=6, |
| 1227 | num_record_batches=3, |
| 1228 | num_dictionary_batches=2, |
| 1229 | num_dictionary_deltas=0, |
| 1230 | num_replaced_dictionaries=1 |
| 1231 | ) |
| 1232 | |
| 1233 | |
| 1234 | def test_flight_do_get_ticket(): |
nothing calls this directly
no test coverage detected