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 ac6e866 commit 8aa2fe7Copy full SHA for 8aa2fe7
services/web/server/src/simcore_service_webserver/celery/plugin.py
@@ -1,15 +1,18 @@
1
import logging
2
3
from aiohttp import web
4
-from servicelib.aiohttp.application_setup import ModuleCategory, app_module_setup
5
+from ..application_setup import ModuleCategory, app_setup_func
6
from ._task_manager import setup_task_manager
7
8
_logger = logging.getLogger(__name__)
9
10
11
-@app_module_setup(
12
- __name__, ModuleCategory.ADDON, settings_name="WEBSERVER_CELERY", logger=_logger
+@app_setup_func(
+ __name__,
13
+ ModuleCategory.ADDON,
14
+ settings_name="WEBSERVER_CELERY",
15
+ logger=_logger,
16
)
17
def setup_celery(app: web.Application):
18
app.cleanup_ctx.append(setup_task_manager)
0 commit comments