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 df41a32 commit d29a277Copy full SHA for d29a277
services/storage/src/simcore_service_storage/api/rest/dependencies/celery.py
@@ -0,0 +1,13 @@
1
+from typing import Annotated
2
+
3
+from fastapi import Depends, FastAPI
4
+from servicelib.fastapi.dependencies import get_app
5
6
+from ....modules.celery import get_celery_client as _get_celery_client_from_app
7
+from ....modules.celery.client import CeleryTaskQueueClient
8
9
10
+def get_celery_client(
11
+ app: Annotated[FastAPI, Depends(get_app)],
12
+) -> CeleryTaskQueueClient:
13
+ return _get_celery_client_from_app(app)
0 commit comments