(self, context, ticket)
| 86 | print(self.flights[key]) |
| 87 | |
| 88 | def do_get(self, context, ticket): |
| 89 | key = ast.literal_eval(ticket.ticket.decode()) |
| 90 | if key not in self.flights: |
| 91 | return None |
| 92 | return pyarrow.flight.RecordBatchStream(self.flights[key]) |
| 93 | |
| 94 | def list_actions(self, context): |
| 95 | return [ |