File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed
src/celery_library/backends
services/storage/src/simcore_service_storage/modules/celery Expand file tree Collapse file tree 3 files changed +3
-3
lines changed File renamed without changes.
Original file line number Diff line number Diff line change 1515)
1616from celery .signals import worker_init , worker_shutdown
1717from celery .worker .worker import WorkController
18- from celery_library .backends ._redis import RedisTaskInfoStore
18+ from celery_library .backends .redis import RedisTaskInfoStore
1919from celery_library .signals import on_worker_init , on_worker_shutdown
2020from celery_library .task_manager import CeleryTaskManager
2121from celery_library .types import register_celery_types
@@ -132,7 +132,7 @@ async def with_celery_worker(
132132 register_celery_tasks : Callable [[Celery ], None ],
133133) -> AsyncIterator [TestWorkController ]:
134134 def _on_worker_init_wrapper (sender : WorkController , ** _kwargs ):
135- return on_worker_init (app_server , sender , ** _kwargs )
135+ return on_worker_init (sender , app_server , ** _kwargs )
136136
137137 worker_init .connect (_on_worker_init_wrapper )
138138 worker_shutdown .connect (on_worker_shutdown )
Original file line number Diff line number Diff line change 11import logging
22
3- from celery_library .backends ._redis import RedisTaskInfoStore
3+ from celery_library .backends .redis import RedisTaskInfoStore
44from celery_library .common import create_app
55from celery_library .task_manager import CeleryTaskManager
66from celery_library .types import register_celery_types , register_pydantic_types
You can’t perform that action at this time.
0 commit comments