(self, context, descriptor, reader, writer)
| 462 | self.options = options |
| 463 | |
| 464 | def do_exchange(self, context, descriptor, reader, writer): |
| 465 | assert reader.stats.num_messages == 0 |
| 466 | if descriptor.descriptor_type != flight.DescriptorType.CMD: |
| 467 | raise pa.ArrowInvalid("Must provide a command descriptor") |
| 468 | elif descriptor.command == b"echo": |
| 469 | return self.exchange_echo(context, reader, writer) |
| 470 | elif descriptor.command == b"get": |
| 471 | return self.exchange_do_get(context, reader, writer) |
| 472 | elif descriptor.command == b"put": |
| 473 | return self.exchange_do_put(context, reader, writer) |
| 474 | elif descriptor.command == b"transform": |
| 475 | return self.exchange_transform(context, reader, writer) |
| 476 | else: |
| 477 | raise pa.ArrowInvalid( |
| 478 | f"Unknown command: {descriptor.command}") |
| 479 | |
| 480 | def exchange_do_get(self, context, reader, writer): |
| 481 | """Emulate DoGet with DoExchange.""" |
nothing calls this directly
no test coverage detected