Skip to content

Commit 2153680

Browse files
authored
Add logic for databricks teardown (#127)
1 parent ae33f6f commit 2153680

2 files changed

Lines changed: 192 additions & 97 deletions

File tree

  • crates/test-framework/src/spicetest/datasets
  • system-adapters/databricks/src

crates/test-framework/src/spicetest/datasets/worker.rs

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -525,9 +525,8 @@ impl SpiceTestQueryWorker {
525525
&query_sets[set_index]
526526
};
527527

528-
let checkpoint_validation_was_active = checkpoint_validation
529-
.as_ref()
530-
.is_some_and(|cv| cv.active);
528+
let checkpoint_validation_was_active =
529+
checkpoint_validation.as_ref().is_some_and(|cv| cv.active);
531530

532531
if !self
533532
.run_query_set(
@@ -851,9 +850,8 @@ impl SpiceTestQueryWorker {
851850
let query_name = Arc::clone(&query.name);
852851
let query_durations = query_durations_for_task;
853852
let mut local_row_counts = BTreeMap::new();
854-
let mut local_checkpoint_validation: Option<
855-
CheckpointValidationState,
856-
> = None;
853+
let mut local_checkpoint_validation: Option<CheckpointValidationState> =
854+
None;
857855
let run_result = self
858856
.run_single_query(
859857
query,

0 commit comments

Comments
 (0)