33800 Docs

← Retour

AI Orchestrator - Phase 3 : Queue System

Date: 17/01/2026 18:20 Status: TERMINE

Objectif

Implmenter le systme de queue pour gestion asynchrone des jobs IA.

Travaux Raliss

1. Structure Fichiers

/stock_8to/33800-stack/ai-data/
  inputs/
  outputs/
  temp/

2. Table PostgreSQL (Supabase)

3. API Endpoints

Endpoint Mthode Description
/api/jobs POST Creer nouveau job
/api/jobs GET Lister jobs
/api/jobs/{id} GET Status dtaill
/api/jobs/{id} DELETE Annuler job pending
/api/jobs/{id}/output/{file} GET Tlcharger output
/api/queue GET Stats queue

4. Worker Loop

5. Connexions Services

Service Host Port Usage
Redis 192.168.1.12 6379 Queue FIFO
PostgreSQL 192.168.1.12 5433 Jobs metadata

6. Dashboard

Tests Raliss

Job Bark TTS

Job MusicGen

Job ComfyUI (18:45)

Job ComfyUI Final Test (23:03)

Fichiers Modifis

Usage API

# Crer job Bark TTS
curl -X POST http://192.168.1.12:5501/api/jobs \
  -H "Content-Type: application/json" \
  -d '{"tool_id":"bark","job_type":"tts","input_params":{"text":"Hello","voice":"v2/en_speaker_3"}}'

# Crer job MusicGen
curl -X POST http://192.168.1.12:5501/api/jobs \
  -H "Content-Type: application/json" \
  -d '{"tool_id":"musicgen","job_type":"music","input_params":{"description":"upbeat electronic","duration":15}}'

# Crer job ComfyUI (SDXL)
curl -X POST http://192.168.1.12:5501/api/jobs \
  -H "Content-Type: application/json" \
  -d '{"tool_id":"comfyui","job_type":"image","input_params":{"prompt":"a sunset over mountains","steps":20}}'

# Status job
curl http://192.168.1.12:5501/api/jobs/{job_id}

# Tlcharger output
curl http://192.168.1.12:5501/api/jobs/{job_id}/output/output.png -o result.png

Executors Disponibles (10 outils)

Tool Type Mode Status
ollama llm Full API ✅
comfyui image Full API ✅
fooocus image Full API ✅
bark tts Full API ✅
musicgen music Full API ✅
facefusion face Full API ✅
wan21 video Passthrough ✅ (instable API)
applio rvc Passthrough ✅ (API complexe)
sadtalker talking Passthrough ✅ (API complexe)
triposr 3d Broken ❌ (torchmcubes)

6 outils Full API : Génération automatisée avec retour des outputs 3 outils Passthrough : Démarre l'outil, retourne URL web 1 outil Broken : Dépendance manquante

FaceFusion Executor (ajouté 21:33)

Wan2.1 Executor (ajouté 21:15)

Fooocus-API (installé 20:41)

Download URLs (ajouté 22:00)

Super Dashboard (ajouté 22:15)

Passthrough Mode (ajouté 22:35)

Pour les outils avec APIs complexes, mode passthrough qui :

Outils en passthrough : | Outil | Raison | Web URL | |-------|--------|---------| | Applio | 130+ endpoints Gradio | http://192.168.1.30:6969 | | SadTalker | Gradio 3.x complexe | http://192.168.1.30:7868 | | Wan2.1 | Crash pendant génération (OOM) | http://192.168.1.30:7860 | | TripoSR | Dépendance manquante | ❌ (erreur claire) |

Réponse passthrough :

{
  "status": "completed",
  "mode": "passthrough",
  "web_url": "http://192.168.1.30:port",
  "message": "Use web interface",
  "instructions": ["1. Open URL...", "2. Upload..."]
}

Git Commits