made fixes based on PR comments

This commit is contained in:
Salman Paracha 2026-01-06 14:04:54 -08:00
parent 7d517ace77
commit c1d56684df
3 changed files with 626 additions and 198 deletions

View file

@ -11,7 +11,7 @@ use tokio_stream::StreamExt;
use tracing::warn;
// Import tracing constants and signals
use crate::signals::{InteractionQuality, SignalAnalyzer, FLAG_MARKER};
use crate::signals::{InteractionQuality, SignalAnalyzer, TextBasedSignalAnalyzer, FLAG_MARKER};
use crate::tracing::{error, llm, signals as signal_constants};
use hermesllm::apis::openai::Message;
@ -145,7 +145,7 @@ impl StreamProcessor for ObservableStreamProcessor {
// Analyze signals if messages are available and add to span attributes
if let Some(ref messages) = self.messages {
let analyzer = SignalAnalyzer::new();
let analyzer = TextBasedSignalAnalyzer::new();
let report = analyzer.analyze(messages);
// Add overall quality

File diff suppressed because it is too large Load diff