build(deps): bump arrow and arrow-flight from 57.3.0 to 58.0.0

Author: dependabot[bot]

Cargo.lock

@@ -114,8 +114,8 @@ url = "2.5.8"
 
 # Dependencies related to Amp subgraphs
 ahash = "0.8.11"
-arrow = { version = "=57.3.0" }
-arrow-flight = { version = "=57.3.0", features = ["flight-sql-experimental"] }
+arrow = { version = "=58.0.0" }
+arrow-flight = { version = "=58.0.0", features = ["flight-sql-experimental"] }
 futures = "0.3.31"
 half = "2.7.1"
 indoc = "2.0.7"

Cargo.toml

@@ -2,7 +2,7 @@ use std::{collections::HashMap, ops::RangeInclusive, time::Duration};
 
 use ahash::RandomState;
 use alloy::primitives::{BlockHash, BlockNumber};
-use arrow::{datatypes::Schema, error::ArrowError};
+use arrow::datatypes::Schema;
 use arrow_flight::{
     decode::DecodedPayload, error::FlightError, flight_service_client::FlightServiceClient,
     sql::client::FlightSqlServiceClient,
@@ -103,9 +103,9 @@ impl Client for FlightClient {
             let flight_info = raw_client
                 .execute(query, TXN_ID)
                 .await
-                .map_err(Error::Service)?;
+                .map_err(Error::service)?;
 
-            flight_info.try_decode_schema().map_err(Error::Service)
+            flight_info.try_decode_schema().map_err(Error::service)
         })
     }
 
@@ -163,14 +163,14 @@ impl Client for FlightClient {
             let flight_info = raw_client
                 .execute(query, TXN_ID)
                 .await
-                .map_err(Error::Service)?;
+                .map_err(Error::service)?;
 
             for (endpoint_index, endpoint) in flight_info.endpoint.into_iter().enumerate() {
                 let Some(ticket) = endpoint.ticket else {
                     continue;
                 };
 
-                let mut stream = raw_client.do_get(ticket).await.map_err(Error::Service)?.into_inner();
+                let mut stream = raw_client.do_get(ticket).await.map_err(Error::service)?.into_inner();
                 let mut batch_index = 0u32;
                 let mut prev_block_ranges = prev_block_ranges.clone();
 
@@ -232,12 +232,18 @@ pub enum Error {
     Connection(#[source] tonic::transport::Error),
 
     #[error("service failed: {0:#}")]
-    Service(#[source] ArrowError),
+    Service(#[source] Box<dyn std::error::Error + Sync + Send>),
 
     #[error("stream failed: {0:#}")]
     Stream(#[source] FlightError),
 }
 
+impl Error {
+    pub fn service<T: std::error::Error + Sync + Send + 'static>(e: T) -> Self {
+        Self::Service(Box::new(e))
+    }
+}
+
 impl error::IsDeterministic for Error {
     fn is_deterministic(&self) -> bool {
         let msg = match self {