merge

server/reflector/views/transcripts.py

@@ -96,6 +96,7 @@ class CreateTranscript(BaseModel):
     name: str
     source_language: str = Field("en")
     target_language: str = Field("en")
+    source_kind: SourceKind | None = None
 
 
 class UpdateTranscript(BaseModel):
@@ -213,7 +214,7 @@ async def transcripts_create(
     user_id = user["sub"] if user else None
     return await transcripts_controller.add(
         info.name,
-        source_kind=SourceKind.LIVE,
+        source_kind=info.source_kind or SourceKind.LIVE,
         source_language=info.source_language,
         target_language=info.target_language,
         user_id=user_id,

server/reflector/views/transcripts_process.py

@@ -34,7 +34,7 @@ async def transcript_process(
         )
 
     if task_is_scheduled_or_active(
-        "reflector.pipelines.main_live_pipeline.task_pipeline_process",
+        "reflector.pipelines.main_file_pipeline.task_pipeline_file_process",
         transcript_id=transcript_id,
     ):
         return ProcessStatus(status="already running")

www/app/(app)/transcripts/new/page.tsx

@@ -21,6 +21,8 @@ import {
   Spacer,
 } from "@chakra-ui/react";
 import { useAuth } from "../../../lib/AuthProvider";
+import type { components } from "../../../reflector-api";
+
 const TranscriptCreate = () => {
   const isClient = typeof window !== "undefined";
   const router = useRouter();
@@ -58,6 +60,7 @@ const TranscriptCreate = () => {
       name,
       source_language: "en",
       target_language: targetLang || "en",
+      source_kind: "live",
     });
   };
 
@@ -69,6 +72,7 @@ const TranscriptCreate = () => {
       name,
       source_language: "en",
       target_language: targetLang || "en",
+      source_kind: "file",
     });
   };
 

www/app/reflector-api.d.ts

@@ -551,6 +551,7 @@ export interface components {
        * @default en
        */
       target_language: string;
+      source_kind?: components["schemas"]["SourceKind"] | null;
     };
     /** DeletionStatus */
     DeletionStatus: {