Skip to content

Commit

Permalink
Update method call for wrapper
Browse files Browse the repository at this point in the history
  • Loading branch information
rtjd6554 committed Feb 20, 2025
1 parent 2f2b034 commit fc039e3
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -194,7 +194,7 @@ void shouldReinitialisePartitionsWhenNoFilesArePresent() {
initialiseWithPartitions(partitionsBefore);

// When
store.initialise(partitionsAfter.buildList());
update(store).initialise(partitionsAfter.buildList());

// Then
assertThat(store.getAllPartitions())
Expand All @@ -213,10 +213,10 @@ void shouldNotReinitialisePartitionsWhenAFileIsPresent() {
.splitToNewChildren("root", "after1", "after2", 10L);
initialiseWithPartitions(partitionsBefore);

store.addFile(factory.partitionFile("before2", 100L));
update(store).addFile(factory.partitionFile("before2", 100L));

// When / Then
assertThatThrownBy(() -> store.initialise(partitionsAfter.buildList()))
assertThatThrownBy(() -> update(store).initialise(partitionsAfter.buildList()))
.isInstanceOf(StateStoreException.class);
assertThat(store.getAllPartitions())
.containsExactlyInAnyOrderElementsOf(partitionsBefore.buildList());
Expand Down

0 comments on commit fc039e3

Please sign in to comment.