|
15 | 15 | */
|
16 | 16 | package org.springframework.ai.openai;
|
17 | 17 |
|
18 |
| -import java.util.ArrayList; |
19 |
| -import java.util.Base64; |
20 |
| -import java.util.HashMap; |
21 |
| -import java.util.HashSet; |
22 |
| -import java.util.List; |
23 |
| -import java.util.Map; |
24 |
| -import java.util.Set; |
25 |
| -import java.util.concurrent.ConcurrentHashMap; |
26 |
| -import java.util.stream.Collectors; |
27 |
| - |
| 18 | +import io.micrometer.observation.Observation; |
| 19 | +import io.micrometer.observation.ObservationRegistry; |
| 20 | +import io.micrometer.observation.contextpropagation.ObservationThreadLocalAccessor; |
28 | 21 | import org.slf4j.Logger;
|
29 | 22 | import org.slf4j.LoggerFactory;
|
30 | 23 | import org.springframework.ai.chat.messages.AssistantMessage;
|
|
70 | 63 | import org.springframework.util.MimeType;
|
71 | 64 | import org.springframework.util.MultiValueMap;
|
72 | 65 | import org.springframework.util.StringUtils;
|
73 |
| - |
74 |
| -import io.micrometer.observation.Observation; |
75 |
| -import io.micrometer.observation.ObservationRegistry; |
76 |
| -import io.micrometer.observation.contextpropagation.ObservationThreadLocalAccessor; |
77 | 66 | import reactor.core.publisher.Flux;
|
78 | 67 | import reactor.core.publisher.Mono;
|
79 | 68 |
|
| 69 | +import java.util.ArrayList; |
| 70 | +import java.util.Base64; |
| 71 | +import java.util.HashMap; |
| 72 | +import java.util.HashSet; |
| 73 | +import java.util.List; |
| 74 | +import java.util.Map; |
| 75 | +import java.util.Set; |
| 76 | +import java.util.concurrent.ConcurrentHashMap; |
| 77 | +import java.util.stream.Collectors; |
| 78 | + |
80 | 79 | /**
|
81 | 80 | * {@link ChatModel} and {@link StreamingChatModel} implementation for {@literal OpenAI}
|
82 | 81 | * backed by {@link OpenAiApi}.
|
@@ -390,7 +389,6 @@ private ChatResponseMetadata from(OpenAiApi.ChatCompletion result, RateLimit rat
|
390 | 389 | .withId(result.id() != null ? result.id() : "")
|
391 | 390 | .withUsage(result.usage() != null ? OpenAiUsage.from(result.usage()) : new EmptyUsage())
|
392 | 391 | .withModel(result.model() != null ? result.model() : "")
|
393 |
| - .withRateLimit(rateLimit) |
394 | 392 | .withKeyValue("created", result.created() != null ? result.created() : 0L)
|
395 | 393 | .withKeyValue("system-fingerprint", result.systemFingerprint() != null ? result.systemFingerprint() : "");
|
396 | 394 | if (rateLimit != null) {
|
|
0 commit comments