From 447bf97854374a5aec4d7a4214763fcc3b9f3848 Mon Sep 17 00:00:00 2001 From: Igor Loskutov Date: Tue, 16 Dec 2025 16:44:15 -0500 Subject: [PATCH] . --- server/reflector/services/transcript_process.py | 11 ++++++----- server/reflector/tools/process_transcript.py | 2 +- server/reflector/views/transcripts_process.py | 2 +- server/tests/test_hatchet_dispatch.py | 2 +- 4 files changed, 9 insertions(+), 8 deletions(-) diff --git a/server/reflector/services/transcript_process.py b/server/reflector/services/transcript_process.py index cfe7a280..be88c417 100644 --- a/server/reflector/services/transcript_process.py +++ b/server/reflector/services/transcript_process.py @@ -54,6 +54,7 @@ class ValidationOk: # transcript currently doesnt always have recording_id recording_id: NonEmptyString | None transcript_id: NonEmptyString + room_id: NonEmptyString | None = None @dataclass @@ -129,13 +130,13 @@ async def validate_transcript_for_processing( pass return ValidationOk( - recording_id=transcript.recording_id, transcript_id=transcript.id + recording_id=transcript.recording_id, + transcript_id=transcript.id, + room_id=transcript.room_id, ) -async def prepare_transcript_processing( - validation: ValidationOk, room_id: str | None = None -) -> PrepareResult: +async def prepare_transcript_processing(validation: ValidationOk) -> PrepareResult: """ Determine processing mode from transcript/recording data. """ @@ -164,7 +165,7 @@ async def prepare_transcript_processing( track_keys=track_keys, transcript_id=validation.transcript_id, recording_id=recording_id, - room_id=room_id, + room_id=validation.room_id, ) return FileProcessingConfig( diff --git a/server/reflector/tools/process_transcript.py b/server/reflector/tools/process_transcript.py index 98db0307..d89e5f57 100644 --- a/server/reflector/tools/process_transcript.py +++ b/server/reflector/tools/process_transcript.py @@ -38,7 +38,7 @@ async def process_transcript_inner( ) -> AsyncResult: validation = await validate_transcript_for_processing(transcript) on_validation(validation) - config = await prepare_transcript_processing(validation, room_id=transcript.room_id) + config = await prepare_transcript_processing(validation) on_preprocess(config) return dispatch_transcript_processing(config, force=force) diff --git a/server/reflector/views/transcripts_process.py b/server/reflector/views/transcripts_process.py index efa0fde8..927cc8a9 100644 --- a/server/reflector/views/transcripts_process.py +++ b/server/reflector/views/transcripts_process.py @@ -45,7 +45,7 @@ async def transcript_process( else: assert_never(validation) - config = await prepare_transcript_processing(validation, room_id=transcript.room_id) + config = await prepare_transcript_processing(validation) if isinstance(config, ProcessError): raise HTTPException(status_code=500, detail=config.detail) diff --git a/server/tests/test_hatchet_dispatch.py b/server/tests/test_hatchet_dispatch.py index 99b5bcd2..05cbe15f 100644 --- a/server/tests/test_hatchet_dispatch.py +++ b/server/tests/test_hatchet_dispatch.py @@ -332,7 +332,7 @@ async def test_prepare_multitrack_config(): ) as mock_rc: mock_rc.get_by_id = AsyncMock(return_value=mock_recording) - result = await prepare_transcript_processing(validation, room_id="test-room") + result = await prepare_transcript_processing(validation) assert isinstance(result, MultitrackProcessingConfig) assert result.bucket_name == "test-bucket"