fix: Move error.rs to protobuf

src/execution_plans/network_coalesce.rs

@@ -3,11 +3,11 @@ use crate::channel_resolver_ext::get_distributed_channel_resolver;
 use crate::common::scale_partitioning_props;
 use crate::config_extension_ext::ContextGrpcMetadata;
 use crate::distributed_physical_optimizer_rule::{NetworkBoundary, limit_tasks_err};
-use crate::errors::{map_flight_to_datafusion_error, map_status_to_datafusion_error};
 use crate::execution_plans::{DistributedTaskContext, StageExec};
 use crate::flight_service::DoGet;
 use crate::metrics::proto::MetricsSetProto;
 use crate::protobuf::{DistributedCodec, StageKey, proto_from_stage};
+use crate::protobuf::{map_flight_to_datafusion_error, map_status_to_datafusion_error};
 use arrow_flight::Ticket;
 use arrow_flight::decode::FlightRecordBatchStream;
 use arrow_flight::error::FlightError;

src/execution_plans/network_shuffle.rs

@@ -3,11 +3,11 @@ use crate::channel_resolver_ext::get_distributed_channel_resolver;
 use crate::common::scale_partitioning;
 use crate::config_extension_ext::ContextGrpcMetadata;
 use crate::distributed_physical_optimizer_rule::NetworkBoundary;
-use crate::errors::{map_flight_to_datafusion_error, map_status_to_datafusion_error};
 use crate::execution_plans::{DistributedTaskContext, StageExec};
 use crate::flight_service::DoGet;
 use crate::metrics::proto::MetricsSetProto;
 use crate::protobuf::{DistributedCodec, StageKey, proto_from_stage};
+use crate::protobuf::{map_flight_to_datafusion_error, map_status_to_datafusion_error};
 use arrow_flight::Ticket;
 use arrow_flight::decode::FlightRecordBatchStream;
 use arrow_flight::error::FlightError;

src/flight_service/do_get.rs

@@ -1,9 +1,10 @@
 use crate::config_extension_ext::ContextGrpcMetadata;
-use crate::errors::datafusion_error_to_tonic_status;
 use crate::execution_plans::{DistributedTaskContext, StageExec};
 use crate::flight_service::service::ArrowFlightEndpoint;
 use crate::flight_service::session_builder::DistributedSessionBuilderContext;
-use crate::protobuf::{DistributedCodec, StageExecProto, StageKey, stage_from_proto};
+use crate::protobuf::{
+    DistributedCodec, StageExecProto, StageKey, datafusion_error_to_tonic_status, stage_from_proto,
+};
 use arrow_flight::Ticket;
 use arrow_flight::encode::FlightDataEncoderBuilder;
 use arrow_flight::error::FlightError;

src/lib.rs

@@ -5,7 +5,6 @@ mod common;
 mod config_extension_ext;
 mod distributed_ext;
 mod distributed_physical_optimizer_rule;
-mod errors;
 mod execution_plans;
 mod flight_service;
 mod metrics;

src/errors/arrow_error.rs → src/protobuf/errors/arrow_error.rs

@@ -1,6 +1,7 @@
-use crate::errors::io_error::IoErrorProto;
 use datafusion::arrow::error::ArrowError;
 
+use crate::protobuf::errors::io_error::IoErrorProto;
+
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct ArrowErrorProto {
     #[prost(string, optional, tag = "1")]

src/errors/datafusion_error.rs → src/protobuf/errors/datafusion_error.rs

@@ -1,9 +1,9 @@
-use crate::errors::arrow_error::ArrowErrorProto;
-use crate::errors::io_error::IoErrorProto;
-use crate::errors::objectstore_error::ObjectStoreErrorProto;
-use crate::errors::parquet_error::ParquetErrorProto;
-use crate::errors::parser_error::ParserErrorProto;
-use crate::errors::schema_error::SchemaErrorProto;
+use crate::protobuf::errors::arrow_error::ArrowErrorProto;
+use crate::protobuf::errors::io_error::IoErrorProto;
+use crate::protobuf::errors::objectstore_error::ObjectStoreErrorProto;
+use crate::protobuf::errors::parquet_error::ParquetErrorProto;
+use crate::protobuf::errors::parser_error::ParserErrorProto;
+use crate::protobuf::errors::schema_error::SchemaErrorProto;
 use datafusion::common::{DataFusionError, Diagnostic};
 use datafusion::logical_expr::sqlparser::parser::ParserError;
 use std::error::Error;

src/errors/mod.rs → src/protobuf/errors/mod.rs

@@ -1,11 +1,12 @@
 #![allow(clippy::upper_case_acronyms, clippy::vec_box)]
 
-use crate::errors::datafusion_error::DataFusionErrorProto;
 use arrow_flight::error::FlightError;
 use datafusion::common::internal_datafusion_err;
 use datafusion::error::DataFusionError;
 use prost::Message;
 
+use crate::protobuf::errors::datafusion_error::DataFusionErrorProto;
+
 mod arrow_error;
 mod datafusion_error;
 mod io_error;

src/protobuf/mod.rs

@@ -1,7 +1,12 @@
 mod distributed_codec;
+mod errors;
 mod stage_proto;
 mod user_codec;
 
 pub(crate) use distributed_codec::DistributedCodec;
+pub(crate) use errors::{
+    datafusion_error_to_tonic_status, map_flight_to_datafusion_error,
+    map_status_to_datafusion_error,
+};
 pub(crate) use stage_proto::{StageExecProto, StageKey, proto_from_stage, stage_from_proto};
 pub(crate) use user_codec::{get_distributed_user_codec, set_distributed_user_codec};