Atualizar app/celery_app.py

app/celery_app.py

@@ -6,7 +6,7 @@ import os
 redis_url = os.getenv("REDIS_URL", "redis://redis:6379/0")
 
 celery = Celery(
-    "safira",
+    "app",
     broker=redis_url,
     backend=redis_url,
 )
@@ -18,3 +18,10 @@ celery.conf.update(
     timezone="UTC",
     enable_utc=True,
 )
+
+celery.conf.task_routes = {
+    "tasks.admin_*": {"queue": "admin"},
+    "tasks.*": {"queue": "default"},
+}
+
+celery.conf.task_default_queue = "default"