fix: api-server worker init

Author: giancarloromeo

packages/celery-library/src/celery_library/signals.py

@@ -13,8 +13,8 @@
 
 
 def on_worker_init(
-    app_server: BaseAppServer,
     sender: WorkController,
+    app_server: BaseAppServer,
     **_kwargs,
 ) -> None:
     startup_complete_event = threading.Event()

services/api-server/src/simcore_service_api_server/celery_worker/worker_main.py

@@ -37,6 +37,4 @@ def worker_init_wrapper(sender, **_kwargs):
     assert _settings.API_SERVER_CELERY  # nosec
     app_server = FastAPIAppServer(app=create_app(_settings))
 
-    return partial(on_worker_init, app_server, _settings.API_SERVER_CELERY)(
-        sender, **_kwargs
-    )
+    return partial(on_worker_init, app_server=app_server)(sender, **_kwargs)

services/storage/src/simcore_service_storage/modules/celery/worker_main.py

@@ -1,4 +1,5 @@
 """Main application to be deployed in for example uvicorn."""
+
 from celery.signals import worker_init, worker_shutdown  # type: ignore[import-untyped]
 from celery_library.common import create_app as create_celery_app
 from celery_library.signals import (
@@ -29,8 +30,8 @@
 app_server = FastAPIAppServer(app=create_app(_settings))
 
 
-def worker_init_wrapper(sender, **_kwargs):
-    return on_worker_init(sender, app_server, **_kwargs)
+def worker_init_wrapper(sender, **kwargs):
+    return on_worker_init(sender, app_server, **kwargs)
 
 
 worker_init.connect(worker_init_wrapper)