diff --git a/backend/app/domains/materials/tasks.py b/backend/app/domains/materials/tasks.py index d3df5b1..80c6d35 100644 --- a/backend/app/domains/materials/tasks.py +++ b/backend/app/domains/materials/tasks.py @@ -8,7 +8,7 @@ import subprocess import uuid from pathlib import Path -from celery import shared_task +from app.tasks.celery_app import celery_app logger = logging.getLogger(__name__) @@ -16,7 +16,7 @@ logger = logging.getLogger(__name__) CATALOG_SCRIPT = Path(os.environ.get("RENDER_SCRIPTS_DIR", "/render-scripts")) / "catalog_assets.py" -@shared_task( +@celery_app.task( name="app.domains.materials.tasks.refresh_asset_library_catalog", queue="thumbnail_rendering", bind=True, @@ -30,6 +30,7 @@ def refresh_asset_library_catalog(self, asset_library_id: str) -> None: """ from sqlalchemy import create_engine from sqlalchemy.orm import Session + import app.models # noqa: F401 — registers all SQLAlchemy models so relationships resolve from app.domains.materials.models import AssetLibrary from app.config import settings