fix
This commit is contained in:
@@ -162,11 +162,6 @@ def process_audio_file(audio_id: str, db: Session):
|
|||||||
file_size = os.path.getsize(file_path)
|
file_size = os.path.getsize(file_path)
|
||||||
logger.info(f"📁 Файл найден: {file_path} (размер: {file_size} bytes)")
|
logger.info(f"📁 Файл найден: {file_path} (размер: {file_size} bytes)")
|
||||||
|
|
||||||
# Проверяем размер файла - минимум 1000 bytes (1KB) для аудио
|
|
||||||
if file_size < 1000:
|
|
||||||
logger.warning(f"⚠️ Файл слишком маленький для аудио ({file_size} bytes), пропускаем: {audio.filename}")
|
|
||||||
return
|
|
||||||
|
|
||||||
# Формируем запрос в GigaAM API
|
# Формируем запрос в GigaAM API
|
||||||
# Пробуем асинхронный endpoint, если не работает - fallback на обычный
|
# Пробуем асинхронный endpoint, если не работает - fallback на обычный
|
||||||
from apiApp.config import GIGAAM_API_URL
|
from apiApp.config import GIGAAM_API_URL
|
||||||
@@ -272,12 +267,6 @@ async def process_all_pending_audio(
|
|||||||
logger.warning(f"⚠️ Файл не найден на диске: {audio.filename}")
|
logger.warning(f"⚠️ Файл не найден на диске: {audio.filename}")
|
||||||
continue
|
continue
|
||||||
|
|
||||||
# Проверяем размер файла
|
|
||||||
file_size = os.path.getsize(file_path)
|
|
||||||
if file_size < 1000:
|
|
||||||
logger.warning(f"⚠️ Файл слишком маленький ({file_size} bytes), пропускаем: {audio.filename}")
|
|
||||||
continue
|
|
||||||
|
|
||||||
# Добавляем в фон (асинхронно)
|
# Добавляем в фон (асинхронно)
|
||||||
# В FastAPI используем BackgroundTasks
|
# В FastAPI используем BackgroundTasks
|
||||||
# Но нужно создавать новую сессию для каждого таска
|
# Но нужно создавать новую сессию для каждого таска
|
||||||
|
|||||||
Reference in New Issue
Block a user