Skip to content

Commit

Permalink
spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
jeremyk-91 committed Sep 3, 2024
1 parent 8671e7f commit 08f3e1a
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ public void setUp() {
public void updateBucketProgressToAtLeastRetriesOnFailure() {
doThrow(GENERIC_RUNTIME_EXCEPTION).doNothing().when(keyValueService).checkAndSet(any());
assertThatCode(() -> bucketProgressStore.updateBucketProgressToAtLeast(
DEFAULT_BUCKET, BucketProgress.createForTimestampProgress(1000L)))
DEFAULT_BUCKET, BucketProgress.createForTimestampProgress(1000L)))
.doesNotThrowAnyException();
verify(keyValueService, times(2)).checkAndSet(any());
}
Expand All @@ -80,7 +80,7 @@ public void updateBucketProgressToAtLeastRetriesOnFailure() {
public void updateBucketProgressToAtLeastDoesNotRetryIndefinitely() {
doThrow(GENERIC_RUNTIME_EXCEPTION).when(keyValueService).checkAndSet(any());
assertThatThrownBy(() -> bucketProgressStore.updateBucketProgressToAtLeast(
DEFAULT_BUCKET, BucketProgress.createForTimestampProgress(1000L)))
DEFAULT_BUCKET, BucketProgress.createForTimestampProgress(1000L)))
.isEqualTo(GENERIC_RUNTIME_EXCEPTION);
verify(keyValueService, times(10)).checkAndSet(any());
}
Expand Down Expand Up @@ -137,7 +137,7 @@ public void updateBucketProgressToAtLeastRetriesWithNewExpectationsIfReceivingCh
Value.create(serializedIntermediateProgressTwo, AtlasDbConstants.TRANSACTION_TS)));

doThrow(createCheckAndSetExceptionForDefaultBucket(
bucketProgress, BucketProgress.createForTimestampProgress(30L)))
bucketProgress, BucketProgress.createForTimestampProgress(30L)))
.doThrow(createCheckAndSetExceptionForDefaultBucket(
bucketProgress, BucketProgress.createForTimestampProgress(70L)))
.doNothing()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,10 @@ public class AbstractDefaultBucketProgressStoreTest {
private static final BucketProgress PROGRESS_ONE_THOUSAND = BucketProgress.createForTimestampProgress(1000L);
private static final BucketProgress PROGRESS_TWO_THOUSAND_NO_CELLS_SWEPT =
BucketProgress.createForTimestampProgress(2000L);
private static final BucketProgress PROGRESS_TWO_THOUSAND_ONE_CELL_SWEPT =
BucketProgress.builder().timestampProgress(2000L).cellProgressForNextTimestamp(0L).build();
private static final BucketProgress PROGRESS_TWO_THOUSAND_ONE_CELL_SWEPT = BucketProgress.builder()
.timestampProgress(2000L)
.cellProgressForNextTimestamp(0L)
.build();

private final KeyValueService kvs;
private final BucketProgressStore store;
Expand Down

0 comments on commit 08f3e1a

Please sign in to comment.