We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6dd7fd7 commit a657d3eCopy full SHA for a657d3e
services/notifications/src/simcore_service_notifications/api/rpc/routes.py
@@ -1,5 +1,6 @@
1
from collections.abc import AsyncIterator
2
3
+from celery_library.rpc import _async_jobs
4
from fastapi import FastAPI
5
from fastapi_lifespan_manager import State
6
from models_library.api_schemas_notifications import NOTIFICATIONS_RPC_NAMESPACE
@@ -9,7 +10,10 @@
9
10
from ...clients.rabbitmq import get_rabbitmq_rpc_server
11
from . import _notifications
12
-ROUTERS: list[RPCRouter] = [_notifications.router]
13
+ROUTERS: list[RPCRouter] = [
14
+ _async_jobs.router,
15
+ _notifications.router,
16
+]
17
18
19
async def rpc_api_routes_lifespan(app: FastAPI) -> AsyncIterator[State]:
services/notifications/tests/unit/test_tasks.py renamed to services/notifications/tests/unit/test_send_email_tasks.py
0 commit comments