(self, context)
| 92 | return pyarrow.flight.RecordBatchStream(self.flights[key]) |
| 93 | |
| 94 | def list_actions(self, context): |
| 95 | return [ |
| 96 | ("clear", "Clear the stored flights."), |
| 97 | ("shutdown", "Shut down this server."), |
| 98 | ] |
| 99 | |
| 100 | def do_action(self, context, action): |
| 101 | if action.type == "clear": |