diff --git a/backend/routers/pipeline.py b/backend/routers/pipeline.py index 393c8c5..b551262 100644 --- a/backend/routers/pipeline.py +++ b/backend/routers/pipeline.py @@ -189,10 +189,10 @@ async def clean_retrigger_pipeline( await db.execute( KeyMoment.__table__.delete().where(KeyMoment.source_video_id == video_id) ) - # Delete transcript segments - await db.execute( - TranscriptSegment.__table__.delete().where(TranscriptSegment.source_video_id == video_id) - ) + # Note: transcript_segments are NOT deleted — they are the pipeline's input + # data created during ingest, not pipeline output. Deleting them would leave + # the pipeline with nothing to process. + # Reset status video.processing_status = ProcessingStatus.not_started await db.commit() @@ -200,7 +200,6 @@ async def clean_retrigger_pipeline( deleted_counts = { "pipeline_events": "cleared", "key_moments": "cleared", - "transcript_segments": "cleared", } # Best-effort Qdrant cleanup (non-blocking)