Hitonabi
dfef585ec8
Ampel / ampel (push) Successful in 28s
- POST /jobs nimmt target_dir (validiert unter /app/media, .. fliegt raus) - GET /storage-targets: Verzeichnisse unter /app/media inkl. Mount-Flag und freiem Platz — NFS/SMB-Shares unter /srv/rippy/media erscheinen dank rslave-Bind automatisch - jobs.target_dir (Mini-Migration via ADD COLUMN IF NOT EXISTS) - Worker: rip_disc(target_dir) mit eigener Validierung; CD/Video/ Transcode-Pfade legen im gewaehlten Ziel ab - UI: "Rippen starten" oeffnet den Ziel-Dialog (Filme/Serien/Musik oder eigener Pfad); Modal-Bugfix: customPath wurde still ignoriert Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
21 lines
677 B
Python
21 lines
677 B
Python
"""Dünner Celery-Client: die API SCHICKT Tasks an den Worker, führt sie nie aus.
|
|
|
|
Bis 23.07. gab es überhaupt keinen Code-Pfad, der je einen Rip auslöste —
|
|
kein POST /jobs, kein udev-Daemon. Dieser Client schließt die Lücke.
|
|
"""
|
|
|
|
import os
|
|
|
|
from celery import Celery
|
|
|
|
REDIS_URL = os.getenv("REDIS_URL", "redis://localhost:6379/0")
|
|
|
|
celery_client = Celery("rippy_api", broker=REDIS_URL, backend=REDIS_URL)
|
|
|
|
|
|
def start_rip(device_path: str, job_id: str, target_dir: str = None):
|
|
"""Schickt den Rip-Task an den Worker (Task-Name aus worker/tasks.py)."""
|
|
return celery_client.send_task(
|
|
"worker.tasks.rip_disc", args=[device_path, job_id, target_dir]
|
|
)
|