Skip to content

Commit 24e9b30

Browse files
committed
Cleanup
1 parent b02d108 commit 24e9b30

File tree

1 file changed

+23
-25
lines changed
  • instrumentation/aws-sdk/aws-sdk-2.2/library/src/main/java/io/opentelemetry/instrumentation/awssdk/v2_2/internal

1 file changed

+23
-25
lines changed

instrumentation/aws-sdk/aws-sdk-2.2/library/src/main/java/io/opentelemetry/instrumentation/awssdk/v2_2/internal/BedrockRuntimeImpl.java

Lines changed: 23 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -53,8 +53,7 @@ static boolean isBedrockRuntimeRequest(SdkRequest request) {
5353
static String getModelId(SdkRequest request) {
5454
if (request instanceof ConverseRequest) {
5555
return ((ConverseRequest) request).modelId();
56-
}
57-
if (request instanceof ConverseStreamRequest) {
56+
} else if (request instanceof ConverseStreamRequest) {
5857
return ((ConverseStreamRequest) request).modelId();
5958
}
6059
return null;
@@ -65,8 +64,7 @@ static Long getMaxTokens(SdkRequest request) {
6564
InferenceConfiguration config = null;
6665
if (request instanceof ConverseRequest) {
6766
config = ((ConverseRequest) request).inferenceConfig();
68-
}
69-
if (request instanceof ConverseStreamRequest) {
67+
} else if (request instanceof ConverseStreamRequest) {
7068
config = ((ConverseStreamRequest) request).inferenceConfig();
7169
}
7270
if (config != null) {
@@ -80,8 +78,7 @@ static Double getTemperature(SdkRequest request) {
8078
InferenceConfiguration config = null;
8179
if (request instanceof ConverseRequest) {
8280
config = ((ConverseRequest) request).inferenceConfig();
83-
}
84-
if (request instanceof ConverseStreamRequest) {
81+
} else if (request instanceof ConverseStreamRequest) {
8582
config = ((ConverseStreamRequest) request).inferenceConfig();
8683
}
8784
if (config != null) {
@@ -95,8 +92,7 @@ static Double getTopP(SdkRequest request) {
9592
InferenceConfiguration config = null;
9693
if (request instanceof ConverseRequest) {
9794
config = ((ConverseRequest) request).inferenceConfig();
98-
}
99-
if (request instanceof ConverseStreamRequest) {
95+
} else if (request instanceof ConverseStreamRequest) {
10096
config = ((ConverseStreamRequest) request).inferenceConfig();
10197
}
10298
if (config != null) {
@@ -110,8 +106,7 @@ static List<String> getStopSequences(SdkRequest request) {
110106
InferenceConfiguration config = null;
111107
if (request instanceof ConverseRequest) {
112108
config = ((ConverseRequest) request).inferenceConfig();
113-
}
114-
if (request instanceof ConverseStreamRequest) {
109+
} else if (request instanceof ConverseStreamRequest) {
115110
config = ((ConverseStreamRequest) request).inferenceConfig();
116111
}
117112
if (config != null) {
@@ -128,11 +123,12 @@ static List<String> getStopReasons(Response response) {
128123
if (reason != null) {
129124
return Collections.singletonList(reason.toString());
130125
}
131-
}
132-
TracingConverseStreamResponseHandler streamHandler =
133-
TracingConverseStreamResponseHandler.fromContext(response.otelContext());
134-
if (streamHandler != null) {
135-
return streamHandler.stopReasons;
126+
} else {
127+
TracingConverseStreamResponseHandler streamHandler =
128+
TracingConverseStreamResponseHandler.fromContext(response.otelContext());
129+
if (streamHandler != null) {
130+
return streamHandler.stopReasons;
131+
}
136132
}
137133
return null;
138134
}
@@ -143,11 +139,12 @@ static Long getUsageInputTokens(Response response) {
143139
TokenUsage usage = null;
144140
if (sdkResponse instanceof ConverseResponse) {
145141
usage = ((ConverseResponse) sdkResponse).usage();
146-
}
147-
TracingConverseStreamResponseHandler streamHandler =
148-
TracingConverseStreamResponseHandler.fromContext(response.otelContext());
149-
if (streamHandler != null) {
150-
usage = streamHandler.usage;
142+
} else {
143+
TracingConverseStreamResponseHandler streamHandler =
144+
TracingConverseStreamResponseHandler.fromContext(response.otelContext());
145+
if (streamHandler != null) {
146+
usage = streamHandler.usage;
147+
}
151148
}
152149
if (usage != null) {
153150
return integerToLong(usage.inputTokens());
@@ -161,11 +158,12 @@ static Long getUsageOutputTokens(Response response) {
161158
TokenUsage usage = null;
162159
if (sdkResponse instanceof ConverseResponse) {
163160
usage = ((ConverseResponse) sdkResponse).usage();
164-
}
165-
TracingConverseStreamResponseHandler streamHandler =
166-
TracingConverseStreamResponseHandler.fromContext(response.otelContext());
167-
if (streamHandler != null) {
168-
usage = streamHandler.usage;
161+
} else {
162+
TracingConverseStreamResponseHandler streamHandler =
163+
TracingConverseStreamResponseHandler.fromContext(response.otelContext());
164+
if (streamHandler != null) {
165+
usage = streamHandler.usage;
166+
}
169167
}
170168
if (usage != null) {
171169
return integerToLong(usage.outputTokens());

0 commit comments

Comments
 (0)