ractogateway.pipelines.video_processor._rag

RactoRAG integration for VideoProcessorPipeline.

Stores extracted video content (visual analyses + transcript segments) into the existing RactoRAG pipeline for subsequent Q&A retrieval.

ractogateway.pipelines.video_processor._rag.store_result_in_rag(result, rag_pipeline)[source]

Ingest all video sections and transcript segments into rag_pipeline.

Parameters:

result (VideoProcessorResult) – The completed VideoProcessorResult to store.
rag_pipeline (Any) – A ractogateway.rag.pipeline.RactoRAG instance (or any object with a compatible add_text(text, metadata) interface).

Return type:

int

Returns:

int – Number of chunks successfully stored.

async ractogateway.pipelines.video_processor._rag.store_result_in_rag_async(result, rag_pipeline)[source]

Async variant of store_result_in_rag().

Falls back to the sync implementation if the rag_pipeline does not expose async add methods.