Skip to content

Commit 77b0aac

Browse files
Addressed comments
1 parent 75fb8b1 commit 77b0aac

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

grpc-circuitbreaker-utils/src/main/java/org/hypertrace/circuitbreaker/grpcutils/CircuitBreakerConfigParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ public class CircuitBreakerConfigParser {
2828
private static final String SLIDING_WINDOW_TYPE = "slidingWindowType";
2929
public static final String ENABLED = "enabled";
3030
public static final String DEFAULT_THRESHOLDS = "defaultThresholds";
31-
private static final Set<String> NON_THRESHOLD_KEYS = Set.of(ENABLED, DEFAULT_THRESHOLDS);
31+
private static final Set<String> NON_THRESHOLD_KEYS = Set.of(ENABLED);
3232

3333
public static <T> CircuitBreakerConfiguration.CircuitBreakerConfigurationBuilder<T> parseConfig(
3434
Config config) {

grpc-circuitbreaker-utils/src/main/java/org/hypertrace/circuitbreaker/grpcutils/resilience/ResilienceCircuitBreakerProvider.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,8 @@ public ResilienceCircuitBreakerProvider(
2929
}
3030

3131
public Optional<CircuitBreaker> getCircuitBreaker(String circuitBreakerKey) {
32-
if (disabledKeys.contains(circuitBreakerKey)) {
32+
if (disabledKeys.contains(circuitBreakerKey)
33+
|| !circuitBreakerConfigMap.containsKey(circuitBreakerKey)) {
3334
return Optional.empty();
3435
}
3536
return Optional.of(

0 commit comments

Comments
 (0)