From a954e6481a62fb1cf95cc619ad278492adaa476a Mon Sep 17 00:00:00 2001 From: Tom Forbes Date: Thu, 5 Dec 2024 21:59:35 +0000 Subject: [PATCH] Fix repo --- src/data.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/data.rs b/src/data.rs index e646fb2..8265aa3 100644 --- a/src/data.rs +++ b/src/data.rs @@ -157,7 +157,7 @@ pub fn merge_parquet_files( .with_multithreaded(true) .with_maintain_order(false), ); - df = df.with_column(lit(repo_id as u32).alias("repository")); + df = df.with_column(lit(repo_id as u32).alias("repository").cast(DataType::UInt32)); let mut df = df.collect()?; let w = File::create(output_path)?; let writer = ParquetWriter::new(BufWriter::new(w))