From a42ed129824899732b1a25228a6a9da479e442a6 Mon Sep 17 00:00:00 2001 From: Igor Loskutov Date: Mon, 11 Aug 2025 19:28:52 -0400 Subject: [PATCH] fix: evaluation cli event wrap (#536) * fix: evaluation cli event wrap * fix: evaluation cli event wrap * chore: remove unrelated change * chore: rollback claude.md changes --- server/reflector/processors/audio_diarization.py | 6 +++++- server/reflector/tools/process_with_diarization.py | 5 ++--- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/server/reflector/processors/audio_diarization.py b/server/reflector/processors/audio_diarization.py index 69eab5b7..2b2ef804 100644 --- a/server/reflector/processors/audio_diarization.py +++ b/server/reflector/processors/audio_diarization.py @@ -1,5 +1,9 @@ from reflector.processors.base import Processor -from reflector.processors.types import AudioDiarizationInput, TitleSummary, Word +from reflector.processors.types import ( + AudioDiarizationInput, + TitleSummary, + Word, +) class AudioDiarizationProcessor(Processor): diff --git a/server/reflector/tools/process_with_diarization.py b/server/reflector/tools/process_with_diarization.py index 49d5cd83..4735c1ca 100644 --- a/server/reflector/tools/process_with_diarization.py +++ b/server/reflector/tools/process_with_diarization.py @@ -145,14 +145,13 @@ async def process_audio_file_with_diarization( logger.info(f"Starting diarization with {len(topics)} topics") try: - # Import diarization processor from reflector.processors import AudioDiarizationAutoProcessor - # Create diarization processor diarization_processor = AudioDiarizationAutoProcessor( name=diarization_backend ) - diarization_processor.on(event_callback) + + diarization_processor.set_pipeline(pipeline) # For Modal backend, we need to upload the file to S3 first if diarization_backend == "modal":