code: def do_get(self, context, ticket):
      print("do_get")
      key = ast.literal_eval(ticket.ticket.decode())
      if key not in self.flights:
          return None
      return pyarrow.flight.RecordBatchStream(self.flights[key])
  
file_path: arrow/r/inst/demo_flight_server.py
imports: import ast
  import threading
  import time
  import pyarrow
  import pyarrow.flight
label_desc: Use image node_id 7 for calling the DemoFlightServer obj's underlying member method code with example usage: obj.do_get(context, ticket) and returns: pyarrow, None