fn output_to_flight_record_batch_source(
output: Output,
should_emit_terminal_metrics: bool,
) -> Result<FlightRecordBatchSource, Status>fn output_to_flight_record_batch_source(
output: Output,
should_emit_terminal_metrics: bool,
) -> Result<FlightRecordBatchSource, Status>