Transcriptor/core/diarize.py

import json
import subprocess
import os

WORKER_SCRIPT = os.path.join(os.path.dirname(__file__), "..", "workers", "diarize_worker.py")


def diarize(audio_file: str) -> list[dict] | None:
    script = os.path.abspath(WORKER_SCRIPT)
    result = subprocess.run(
        [script, audio_file],
        capture_output=True,
        text=True,
        encoding="utf-8",
        check=True,
    )
    return json.loads(result.stdout)