Function _spawn_telemetry

pr_fetch.py:545–563

(vid: str, pr_blob: str, strategy_id: str)

def _spawn_telemetry(vid: str, pr_blob: str, strategy_id: str) -> None:
    rec_ids = []
    try:
        rec_ids = _extract_recommended_video_ids(pr_blob)[:8]
    except Exception:
        pass
    ids = [vid] + rec_ids
    args = [sys.executable, str(Path(__file__).resolve()),
            "--telemetry", strategy_id, ",".join(ids)]
    try:
        subprocess.Popen(
            args,
            stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL,
            stdin=subprocess.DEVNULL,
            start_new_session=True,
            env=os.environ.copy(),
        )
    except Exception as e:
        _log(f"failed to spawn telemetry: {e}")


def _extract_recommended_video_ids(pr_blob: str) -> list[str]: