fix wrong assert

datafast-network · Dec 5, 2023 · 15d9bac · 15d9bac
1 parent 4d871c8
commit 15d9bac
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ingestor/src/producers/delta.rs b/ingestor/src/producers/delta.rs
@@ -114,7 +114,7 @@ impl DeltaLakeProducer {
         let arrow_schema = <ArrowSchema as TryFrom<&Schema>>::try_from(&metadata.schema.clone())
             .map_err(|e| ProducerError::Initialization(format!("{:?}", e)))?;
 
-        assert_eq!(arrow_schema.fields.len(), 5);
+        assert_eq!(arrow_schema.fields.len(), 6);
         let schema_ref = Arc::new(arrow_schema);
 
         let writer = RecordBatchWriter::for_table(&table)?;