File tree Expand file tree Collapse file tree 2 files changed +2
-6
lines changed
src/simcore_service_storage/modules/celery Expand file tree Collapse file tree 2 files changed +2
-6
lines changed Original file line number Diff line number Diff line change 11"""Main application to be deployed in for example uvicorn."""
2-
3- from functools import partial
4-
52from celery .signals import worker_init , worker_shutdown # type: ignore[import-untyped]
63from celery_library .common import create_app as create_celery_app
74from celery_library .signals import (
3431
3532def worker_init_wrapper (sender , ** _kwargs ):
3633 assert _settings .STORAGE_CELERY # nosec
37- return partial ( on_worker_init , app_server )( sender , ** _kwargs )
34+ return on_worker_init ( sender , app_server , ** _kwargs )
3835
3936
4037worker_init .connect (worker_init_wrapper )
Original file line number Diff line number Diff line change 1212import random
1313import sys
1414from collections .abc import AsyncIterator , Awaitable , Callable
15- from functools import partial
1615from pathlib import Path
1716from typing import Any , Final , cast
1817
@@ -1019,7 +1018,7 @@ async def with_storage_celery_worker(
10191018
10201019 def _on_worker_init_wrapper (sender : WorkController , ** _kwargs ):
10211020 assert app_settings .STORAGE_CELERY # nosec
1022- return partial ( on_worker_init , app_server )( sender , ** _kwargs )
1021+ return on_worker_init ( sender , app_server , ** _kwargs )
10231022
10241023 worker_init .connect (_on_worker_init_wrapper )
10251024 worker_shutdown .connect (on_worker_shutdown )
You can’t perform that action at this time.
0 commit comments