Skip to content

Commit

Permalink
feat: check constraints, fix a lint
Browse files Browse the repository at this point in the history
  • Loading branch information
scarman-db committed Dec 9, 2023
1 parent b475f29 commit c5e23c1
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions crates/deltalake-core/src/delta_datafusion/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1098,13 +1098,12 @@ impl DeltaDataChecker {

let dfs: Vec<RecordBatch> = self.ctx.sql(&sql).await?.collect().await?;
if !dfs.is_empty() && dfs[0].num_rows() > 0 {
let values: String = dfs[0]
let value: String = dfs[0]
.columns()
.iter()
.map(|c| array_value_to_string(c, 0).unwrap_or(String::from("null")))
.join(", ");

let value = format!("{}", values);
let msg = format!(
"Check or Invariant ({}) violated by value in row: [{}]",
check.get_expression(),
Expand Down

0 comments on commit c5e23c1

Please sign in to comment.