Function query_to_arrow 

pub async fn query_to_arrow<'a>(
    conn: &'a mut PgConnection,
    query: &str,
) -> Result<(Arc<Schema>, impl Stream<Item = Result<RecordBatch>> + 'a)>