Skip to main content

classify_flight_error

micromegas::servers::flight_sql_service_impl

Function classify_flight_error 

Source 
pub fn classify_flight_error(
    err: FlightError,
    query_id: &str,
    plan: Option<&Arc<dyn ExecutionPlan>>,
) -> Status
Expand description

Recovers the DataFusionError from the per-batch FlightError re-wrap (FlightError::ExternalError(Box::new(e)), applied once the raw DataFusionError stream is wrapped for Arrow Flight) and classifies it via client_error. Every branch logs exactly once before returning, so this is a single, unconditional log point for the per-batch stream-error site regardless of which branch is taken. pub so step 9’s external integration tests can exercise this recovery path directly.