We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3c173d5 commit 0378bdbCopy full SHA for 0378bdb
backend/app/app/api/celery_task.py
@@ -5,7 +5,6 @@
5
from app.core.celery import celery
6
from app.models.hero_model import Hero
7
from app.db.session import SessionLocal
8
-from asyncer import runnify
9
import logging
10
from celery import Task
11
from transformers import pipeline
@@ -67,6 +66,6 @@ async def get_hero(hero_id: UUID) -> Hero:
67
66
68
69
@celery.task(name="tasks.print_hero")
70
-def print_hero(hero_id: UUID) -> None:
71
- hero = runnify(get_hero)(hero_id=hero_id)
+def print_hero(hero_id: UUID) -> None:
+ hero = asyncio.get_event_loop().run_until_complete(get_hero(hero_id=hero_id))
72
return hero.id
0 commit comments