[~] Refactor
This commit is contained in:
parent
d7832d7574
commit
081e49f3a5
@ -18,7 +18,6 @@ def shared_task(*args: Any, **kwargs: Any) -> Any:
|
|||||||
class Task(celery.app.task.Task):
|
class Task(celery.app.task.Task):
|
||||||
def __call__(self, *args, **kwargs) -> Any:
|
def __call__(self, *args, **kwargs) -> Any:
|
||||||
res = super().__call__(*args, **kwargs)
|
res = super().__call__(*args, **kwargs)
|
||||||
print([res, inspect.isawaitable(res)])
|
|
||||||
if inspect.isawaitable(res):
|
if inspect.isawaitable(res):
|
||||||
return asyncio.run(res)
|
return asyncio.run(res)
|
||||||
else:
|
else:
|
||||||
|
Loading…
Reference in New Issue
Block a user