cargo fmt

Author: getChan

Cargo.toml

@@ -200,10 +200,10 @@ unexpected_cfgs = { level = "warn", check-cfg = [
 unused_qualifications = "deny"
 
 
-# TEMPORARY: override arrow-avro for testing
+# FIXME - TEMPORARY override arrow-avro for testing
 [patch.crates-io]
-arrow = { git = "https://github.com/apache/arrow-rs.git", rev = "b444ea7127ebc8136564bc9af036353d0c90991b" }
-arrow-avro = { git = "https://github.com/apache/arrow-rs.git", rev = "b444ea7127ebc8136564bc9af036353d0c90991b" }
+arrow = { git = "https://github.com/apache/arrow-rs.git", rev = "d49f017fe1c6712ba32e2222c6f031278b588ca5" }
+arrow-avro = { git = "https://github.com/apache/arrow-rs.git", rev = "d49f017fe1c6712ba32e2222c6f031278b588ca5" }
 
 # --------------------
 # Compilation Profiles

datafusion/common/Cargo.toml

@@ -71,7 +71,7 @@ log = { workspace = true }
 object_store = { workspace = true, optional = true }
 parquet = { workspace = true, optional = true, default-features = true }
 paste = "1.0.15"
-pyo3 = { version = "0.26.0", optional = true }
+pyo3 = { version = "0.26.0", optional = true } # fixme - revert
 recursive = { workspace = true, optional = true }
 sqlparser = { workspace = true, optional = true }
 tokio = { workspace = true }

datafusion/datasource-avro/src/source.rs

@@ -52,7 +52,9 @@ impl AvroSource {
     }
 
     fn open<R: std::io::Read>(&self, reader: R) -> Result<Reader<R>> {
-        let avro_schema = AvroSchema::try_from(self.schema.expect("Schema must set before open").as_ref())?;
+        let avro_schema = AvroSchema::try_from(
+            self.schema.expect("Schema must set before open").as_ref(),
+        )?;
         ReaderBuilder::new()
             .with_reader_schema(avro_schema)
             .with_batch_size(self.batch_size.expect("Batch size must set before open"))