diff --git a/7project/backend/app/workers/celery_tasks.py b/7project/backend/app/workers/celery_tasks.py index 0831e69..053e886 100644 --- a/7project/backend/app/workers/celery_tasks.py +++ b/7project/backend/app/workers/celery_tasks.py @@ -77,7 +77,7 @@ def load_transactions(user_id: str) -> None: logger.info("[Celery] Finished load_transactions | user_id=%s", user_id) -@celery_app.task +@celery_app.task(name="workers.load_all_transactions") def load_all_transactions() -> None: logger.info("[Celery] Starting load_all_transactions") # Now use synchronous bank scraper functions directly