Merge branch 'feature/pipeline-fix' into development

worker/pyproject.toml

@@ -34,3 +34,20 @@ packages = ["src/worker"]
 [tool.pytest.ini_options]
 asyncio_mode = "auto"
 testpaths = ["tests"]
+
+[tool.ruff]
+src = ["src"]
+line-length = 100
+target-version = "py312"
+
+[tool.ruff.lint]
+select = ["E", "F", "I", "UP", "B", "SIM"]
+ignore = ["F401", "F841", "SIM102", "SIM211", "UP045", "E501", "UP017"]
+
+[tool.ruff.lint.per-file-ignores]
+"tests/*" = ["F401", "F841", "SIM102", "SIM211", "UP017", "I001", "B017", "SIM117"]
+
+[dependency-groups]
+dev = [
+    "ruff>=0.15.8",
+]

worker/src/worker/config.py

@@ -1,4 +1,5 @@
 from functools import lru_cache
+
 from pydantic_settings import BaseSettings, SettingsConfigDict
 
 

worker/src/worker/db.py

@@ -6,7 +6,7 @@ import uuid
 from datetime import datetime
 from typing import Optional
 
-from sqlalchemy import BigInteger, Boolean, DateTime, ForeignKey, Integer, Numeric, String, Text, func
+from sqlalchemy import BigInteger, DateTime, Integer, Numeric, String, Text, func
 from sqlalchemy.dialects.postgresql import ARRAY, JSONB, UUID
 from sqlalchemy.orm import DeclarativeBase, Mapped, mapped_column
 

worker/src/worker/main.py

@@ -13,7 +13,7 @@ from pathlib import Path
 import librosa
 import numpy as np
 import redis.asyncio as aioredis
-from sqlalchemy import select, update
+from sqlalchemy import update
 from sqlalchemy.ext.asyncio import AsyncSession, async_sessionmaker, create_async_engine
 
 from worker.config import get_settings

worker/src/worker/pipeline/analyse_full.py

@@ -27,6 +27,7 @@ async def run_full_analysis(
     fields: dict[str, Any] = {**bpm_result.fields, **key_result.fields}
 
     from sqlalchemy import update
+
     from worker.db import AudioVersionModel
 
     global_bpm = fields.get("bpm")

worker/src/worker/pipeline/transcode.py

@@ -5,10 +5,6 @@ from __future__ import annotations
 import asyncio
 import json
 import os
-import shutil
-import subprocess
-import tempfile
-from pathlib import Path
 
 
 async def transcode_to_hls(input_path: str, output_dir: str) -> str:

worker/uv.lock

@@ -1004,6 +1004,11 @@ dev = [
     { name = "ruff" },
 ]
 
+[package.dev-dependencies]
+dev = [
+    { name = "ruff" },
+]
+
 [package.metadata]
 requires-dist = [
     { name = "asyncpg", specifier = ">=0.29" },
@@ -1023,6 +1028,9 @@ requires-dist = [
 ]
 provides-extras = ["dev"]
 
+[package.metadata.requires-dev]
+dev = [{ name = "ruff", specifier = ">=0.15.8" }]
+
 [[package]]
 name = "requests"
 version = "2.33.1"