From a16559e668bf79ea2855e4a15e167177cc3ca38b Mon Sep 17 00:00:00 2001 From: jlightner Date: Fri, 3 Apr 2026 05:58:14 +0000 Subject: [PATCH] fix: add /app to sys.path for Celery forked workers importing services.avatar --- backend/pipeline/stages.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/backend/pipeline/stages.py b/backend/pipeline/stages.py index 8415d0f..36278cc 100644 --- a/backend/pipeline/stages.py +++ b/backend/pipeline/stages.py @@ -2388,7 +2388,11 @@ def fetch_creator_avatar(creator_id: str) -> dict: avatar_url/avatar_source/avatar_fetched_at columns if a confident match is found. Returns a status dict. """ + import sys from datetime import datetime, timezone + # Ensure /app is on sys.path for forked Celery workers + if "/app" not in sys.path: + sys.path.insert(0, "/app") from services.avatar import lookup_avatar session = _get_sync_session()