We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 62c5de9 commit c60b3c3Copy full SHA for c60b3c3
dd-java-agent/agent-llmobs/src/main/java/datadog/trace/llmobs/EvalProcessingWorker.java
@@ -145,7 +145,11 @@ public void run() {
145
private void runDutyCycle() throws InterruptedException {
146
Thread thread = Thread.currentThread();
147
while (!thread.isInterrupted()) {
148
- consumeBatch();
+ LLMObsEval eval = queue.poll(100, TimeUnit.MILLISECONDS);
149
+ if (eval != null) {
150
+ buffer.add(eval);
151
+ consumeBatch();
152
+ }
153
flushIfNecessary();
154
}
155
0 commit comments