diff --git a/whisper_fastapi_online_server.py b/whisper_fastapi_online_server.py index f399fc4..7684705 100644 --- a/whisper_fastapi_online_server.py +++ b/whisper_fastapi_online_server.py @@ -10,7 +10,7 @@ from fastapi import FastAPI, WebSocket, WebSocketDisconnect from fastapi.responses import HTMLResponse from fastapi.middleware.cors import CORSMiddleware -from whisper_streaming_custom.whisper_online import backend_factory, online_factory, add_shared_args,warmup_asr +from whisper_streaming_custom.whisper_online import backend_factory, online_factory, add_shared_args, warmup_asr from timed_objects import ASRToken import math @@ -42,8 +42,13 @@ parser.add_argument( parser.add_argument( "--warmup-file", type=str, + default=None, dest="warmup_file", - help="The path to a speech audio wav file to warm up Whisper so that the very first chunk processing is fast. It can be e.g. https://github.com/ggerganov/whisper.cpp/raw/master/samples/jfk.wav .", + help=""" + The path to a speech audio wav file to warm up Whisper so that the very first chunk processing is fast. + If not set, uses https://github.com/ggerganov/whisper.cpp/raw/master/samples/jfk.wav. + If False, no warmup is performed. + """, ) parser.add_argument( diff --git a/whisper_streaming_custom/whisper_online.py b/whisper_streaming_custom/whisper_online.py index ea52062..617f05b 100644 --- a/whisper_streaming_custom/whisper_online.py +++ b/whisper_streaming_custom/whisper_online.py @@ -227,34 +227,57 @@ def asr_factory(args, logfile=sys.stderr): online = online_factory(args, asr, tokenizer, logfile=logfile) return asr, online -def warmup_asr(asr, warmup_file=None): +def warmup_asr(asr, warmup_file=None, timeout=5): """ Warmup the ASR model by transcribing a short audio file. """ - if warmup_file: - warmup_file = warmup_file - else: + import os + import tempfile + + + if warmup_file is None: # Download JFK sample if not already present - import tempfile - import os - - jfk_url = "https://github.com/ggerganov/whisper.cpp/raw/master/samples/jfk.wav" temp_dir = tempfile.gettempdir() warmup_file = os.path.join(temp_dir, "whisper_warmup_jfk.wav") if not os.path.exists(warmup_file): logger.debug(f"Downloading warmup file from {jfk_url}") + print(f"Downloading warmup file from {jfk_url}") + import time import urllib.request - urllib.request.urlretrieve(jfk_url, warmup_file) - - - # Load the warmup file - audio, sr = librosa.load(warmup_file, sr=16000) - + import urllib.error + import socket + + original_timeout = socket.getdefaulttimeout() + socket.setdefaulttimeout(timeout) + + start_time = time.time() + try: + urllib.request.urlretrieve(jfk_url, warmup_file) + logger.debug(f"Download successful in {time.time() - start_time:.2f}s") + except (urllib.error.URLError, socket.timeout) as e: + logger.warning(f"Download failed: {e}. Proceeding without warmup.") + return False + finally: + socket.setdefaulttimeout(original_timeout) + elif not warmup_file: + return False + + if not warmup_file or not os.path.exists(warmup_file) or os.path.getsize(warmup_file) == 0: + logger.warning(f"Warmup file {warmup_file} invalid or missing.") + return False + + print(f"Warmping up Whisper with {warmup_file}") + try: + import librosa + audio, sr = librosa.load(warmup_file, sr=16000) + except Exception as e: + logger.warning(f"Failed to load audio file: {e}") + return False + # Process the audio asr.transcribe(audio) - logger.info("Whisper is warmed up")