fix: remove unused param

Author: giancarloromeo

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

@@ -6,7 +6,6 @@
 from celery.worker.worker import WorkController  # type: ignore[import-untyped]
 from servicelib.celery.app_server import BaseAppServer
 from servicelib.logging_utils import log_context
-from settings_library.celery import CelerySettings
 
 from .utils import get_app_server, set_app_server
 
@@ -15,7 +14,6 @@
 
 def on_worker_init(
     app_server: BaseAppServer,
-    celery_settings: CelerySettings,
     sender: WorkController,
     **_kwargs,
 ) -> None:

packages/celery-library/tests/conftest.py

@@ -102,7 +102,7 @@ async def with_celery_worker(
     register_celery_tasks: Callable[[Celery], None],
 ) -> AsyncIterator[TestWorkController]:
     def _on_worker_init_wrapper(sender: WorkController, **_kwargs):
-        return partial(on_worker_init, app_server, celery_settings)(sender, **_kwargs)
+        return partial(on_worker_init, app_server)(sender, **_kwargs)
 
     worker_init.connect(_on_worker_init_wrapper)
     worker_shutdown.connect(on_worker_shutdown)

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

@@ -34,9 +34,7 @@
 
 def worker_init_wrapper(sender, **_kwargs):
     assert _settings.STORAGE_CELERY  # nosec
-    return partial(on_worker_init, app_server, _settings.STORAGE_CELERY)(
-        sender, **_kwargs
-    )
+    return partial(on_worker_init, app_server)(sender, **_kwargs)
 
 
 worker_init.connect(worker_init_wrapper)

services/storage/tests/conftest.py

@@ -1019,9 +1019,7 @@ async def with_storage_celery_worker(
 
     def _on_worker_init_wrapper(sender: WorkController, **_kwargs):
         assert app_settings.STORAGE_CELERY  # nosec
-        return partial(on_worker_init, app_server, app_settings.STORAGE_CELERY)(
-            sender, **_kwargs
-        )
+        return partial(on_worker_init, app_server)(sender, **_kwargs)
 
     worker_init.connect(_on_worker_init_wrapper)
     worker_shutdown.connect(on_worker_shutdown)