selfhostyourtech/reflector
2
0
Fork 0
mirror of https://github.com/Monadical-SAS/reflector.git synced 2025-12-23 05:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

self-review

Browse Source
This commit is contained in:
Igor Loskutov
2025-12-22 18:18:03 -05:00
parent 2cbc373cc3
commit 4b495417b5
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
server/reflector/hatchet/workflows/diarization_pipeline.py
View File

@@ -604,9 +604,7 @@ async def detect_topics(input: PipelineInput, ctx: Context) -> TopicsResult:
results = await topic_chunk_workflow.aio_run_many(bulk_runs) results = await topic_chunk_workflow.aio_run_many(bulk_runs)
topic_chunks = [ topic_chunks = [
TopicChunkResult(**result["detect_chunk_topic"]) TopicChunkResult(**result["detect_chunk_topic"]) for result in results
for result in results
if "detect_chunk_topic" in result
] ]
async with fresh_db_connection(): async with fresh_db_connection():
@@ -813,7 +811,6 @@ async def process_subjects(input: PipelineInput, ctx: Context) -> ProcessSubject
subject_summaries = [ subject_summaries = [
SubjectSummaryResult(**result["generate_detailed_summary"]) SubjectSummaryResult(**result["generate_detailed_summary"])
for result in results for result in results
if "generate_detailed_summary" in result
] ]
ctx.log(f"process_subjects complete: {len(subject_summaries)} summaries") ctx.log(f"process_subjects complete: {len(subject_summaries)} summaries")