Skip to content

Commit

Permalink
fix: init analytics service in celery worker
Browse files Browse the repository at this point in the history
  • Loading branch information
Nandan committed Feb 10, 2025
1 parent ebedbad commit 4587a50
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions app/celery/tasks/parsing_tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
from app.core.database import SessionLocal
from app.modules.parsing.graph_construction.parsing_schema import ParsingRequest
from app.modules.parsing.graph_construction.parsing_service import ParsingService
from app.core.dependencies import get_analytics_service
from app.core.dependencies import init_analytics_service

logger = logging.getLogger(__name__)

Expand Down Expand Up @@ -43,7 +43,7 @@ def process_parsing(
) -> None:
logger.info(f"Task received: Starting parsing process for project {project_id}")
try:
analytics_service = get_analytics_service()
analytics_service = init_analytics_service()
parsing_service = ParsingService(self.db, user_id, analytics_service)

async def run_parsing():
Expand Down

0 comments on commit 4587a50

Please sign in to comment.