add test task celery

Author: sumaro2101

api_v1/users/tasks.py

@@ -0,0 +1,11 @@
+from config import celery_app
+import asyncio
+
+
+@celery_app.task
+async def time_sleep_task():
+    """
+    Тестовая задача для Celery
+    """
+    asyncio.sleep(2.0)
+    return 'Task is done'

app_includes/logs_errors.py

@@ -10,6 +10,9 @@
 
 
 def register_errors(app: FastAPI) -> None:
+    """
+    Крючек для логирования различных исключений
+    """
     @app.exception_handler(ValidationError)
     async def validation_error_handler(
         request: Request,

config/celery/connection.py

@@ -9,7 +9,7 @@
 
 class Celery(celery.Celery):
     """
-    Инициализация Celery
+    Инициализация асинхронного Celery
     """
 
     def __init__(self, *args, **kwargs) -> None:
@@ -41,4 +41,4 @@ def wrapper(*args,
 
 app = Celery(__name__)
 app.conf.broker_url = settings.rabbit.broker_url
-app.autodiscover_tasks(packages=[])
+app.autodiscover_tasks(packages=['api_v1.users'])