Skip to content

Commit 8a77237

Browse files
Fix linting errors.
1 parent e78c137 commit 8a77237

File tree

2 files changed

+33
-8
lines changed

2 files changed

+33
-8
lines changed

databricks-sdk-java/src/main/java/com/databricks/sdk/core/oauth/CachedTokenSource.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ private CachedTokenSource(Builder builder) {
7373
this.expiryBuffer = builder.expiryBuffer;
7474
this.clockSupplier = builder.clockSupplier;
7575
this.token = builder.token;
76-
76+
7777
if (this.useDynamicStaleDuration && this.token != null) {
7878
this.dynamicStaleDuration = computeStaleDuration(this.token);
7979
} else {
@@ -212,7 +212,7 @@ private Duration computeStaleDuration(Token t) {
212212
if (ttl.compareTo(Duration.ZERO) <= 0) {
213213
return Duration.ZERO;
214214
}
215-
215+
216216
Duration halfTtl = ttl.dividedBy(2);
217217
return halfTtl.compareTo(MAX_STALE_DURATION) > 0 ? MAX_STALE_DURATION : halfTtl;
218218
}

databricks-sdk-java/src/test/java/com/databricks/sdk/core/oauth/CachedTokenSourceTest.java

Lines changed: 31 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -39,12 +39,33 @@ public class CachedTokenSourceTest {
3939
private static Stream<Arguments> provideAsyncRefreshScenarios() {
4040
return Stream.of(
4141
Arguments.of("Fresh token, async enabled", FRESH_MINUTES, 0L, false, false, INITIAL_TOKEN),
42-
Arguments.of("Stale token, async enabled", STALE_MINUTES, STALE_ADVANCE_MINUTES, false, true, INITIAL_TOKEN),
43-
Arguments.of("Expired token, async enabled", EXPIRED_MINUTES, 0L, false, true, REFRESH_TOKEN),
42+
Arguments.of(
43+
"Stale token, async enabled",
44+
STALE_MINUTES,
45+
STALE_ADVANCE_MINUTES,
46+
false,
47+
true,
48+
INITIAL_TOKEN),
49+
Arguments.of(
50+
"Expired token, async enabled", EXPIRED_MINUTES, 0L, false, true, REFRESH_TOKEN),
4451
Arguments.of("Fresh token, async disabled", FRESH_MINUTES, 0L, true, false, INITIAL_TOKEN),
45-
Arguments.of("Stale token, async disabled", STALE_MINUTES, STALE_ADVANCE_MINUTES, true, false, INITIAL_TOKEN),
46-
Arguments.of("Stale token, capped stale duration, async enabled", CAPPED_STALE_MINUTES, CAPPED_STALE_ADVANCE_MINUTES, false, true, INITIAL_TOKEN),
47-
Arguments.of("Expired token, async disabled", EXPIRED_MINUTES, 0L, true, true, REFRESH_TOKEN));
52+
Arguments.of(
53+
"Stale token, async disabled",
54+
STALE_MINUTES,
55+
STALE_ADVANCE_MINUTES,
56+
true,
57+
false,
58+
INITIAL_TOKEN),
59+
Arguments.of(
60+
"Stale token, capped stale duration, async enabled",
61+
CAPPED_STALE_MINUTES,
62+
CAPPED_STALE_ADVANCE_MINUTES,
63+
false,
64+
true,
65+
INITIAL_TOKEN),
66+
Arguments.of(
67+
"Expired token, async disabled", EXPIRED_MINUTES, 0L, true, true, REFRESH_TOKEN)
68+
);
4869
}
4970

5071
@ParameterizedTest(name = "{0}")
@@ -67,7 +88,11 @@ void testAsyncRefreshParametrized(
6788
null,
6889
Instant.now(clockSupplier.getClock()).plus(Duration.ofMinutes(minutesUntilExpiry)));
6990
Token refreshedToken =
70-
new Token(REFRESH_TOKEN, TOKEN_TYPE, null, Instant.now(clockSupplier.getClock()).plus(Duration.ofMinutes(10)));
91+
new Token(
92+
REFRESH_TOKEN,
93+
TOKEN_TYPE,
94+
null,
95+
Instant.now(clockSupplier.getClock()).plus(Duration.ofMinutes(10)));
7196
CountDownLatch refreshCalled = new CountDownLatch(1);
7297

7398
TokenSource tokenSource =

0 commit comments

Comments
 (0)