| 2551 | schema = pa.schema([("int64", pa.int64())]) |
| 2552 | |
| 2553 | class FailServer(flight.FlightServerBase): |
| 2554 | def do_put(self, context, descriptor, reader, writer): |
| 2555 | raise exc |
| 2556 | |
| 2557 | def do_exchange(self, context, descriptor, reader, writer): |
| 2558 | raise exc |
| 2559 | |
| 2560 | with FailServer() as server, \ |
| 2561 | FlightClient(('localhost', server.port)) as client: |
no outgoing calls