Skip to content

Commit

Permalink
fixup! Add a simple failing tests for CDF reading
Browse files Browse the repository at this point in the history
  • Loading branch information
rtyler committed Apr 25, 2024
1 parent e27d46b commit f47f76f
Showing 1 changed file with 20 additions and 5 deletions.
25 changes: 20 additions & 5 deletions crates/core/src/operations/update.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1055,11 +1055,26 @@ mod tests {
collect_batches(table.output_partitioning().partition_count(), table, ctx).await
.expect("Failed to collect batches");

assert_batches_sorted_eq! {
["+--------+------------------+-----------------+-------------------------+",
"| value | _change_type | _commit_version | _commit_timestamp |",
"+--------+------------------+-----------------+-------------------------+",
"+--------+------------------+-----------------+-------------------------+"
assert_batches_sorted_eq! {[
"+-------+--------------+-----------------+-------------------------+",
"| value | _change_type | _commit_version | _commit_timestamp |",
"+-------+--------------+-----------------+-------------------------+",
"| | insert | 1 | 2024-04-25T05:10:11.047 |",
"| | insert | 1 | 2024-04-25T05:10:11.047 |",
"| | insert | 2 | 2024-04-25T05:10:11.060 |",
"| | insert | 2 | 2024-04-25T05:10:11.060 |",
"| | insert | 3 | 2024-04-25T05:10:11.067 |",
"| | insert | 3 | 2024-04-25T05:10:11.067 |",
"| 0 | insert | 1 | 2024-04-25T05:10:11.047 |",
"| 0 | insert | 2 | 2024-04-25T05:10:11.060 |",
"| 0 | insert | 3 | 2024-04-25T05:10:11.067 |",
"| 2 | insert | 1 | 2024-04-25T05:10:11.047 |",
"| 3 | insert | 2 | 2024-04-25T05:10:11.060 |",
"| 4 | insert | 1 | 2024-04-25T05:10:11.047 |",
"| 4 | insert | 2 | 2024-04-25T05:10:11.060 |",
"| 4 | insert | 3 | 2024-04-25T05:10:11.067 |",
"| 7 | insert | 3 | 2024-04-25T05:10:11.067 |",
"+-------+--------------+-----------------+-------------------------+",
], &batches }
}

Expand Down

0 comments on commit f47f76f

Please # to comment.