rename

Author: sanderegg

services/storage/tests/unit/test_modules_celery.py

@@ -27,8 +27,8 @@
     TaskState,
 )
 from simcore_service_storage.modules.celery.utils import (
-    get_celery_worker,
     get_fastapi_app,
+    get_with_storage_celery_worker,
 )
 from simcore_service_storage.modules.celery.worker import CeleryTaskQueueWorker
 from tenacity import Retrying, retry_if_exception_type, stop_after_delay, wait_fixed
@@ -49,7 +49,7 @@ def celery_client(
 async def _async_archive(
     celery_app: Celery, task_name: str, task_id: str, files: list[str]
 ) -> str:
-    worker = get_celery_worker(celery_app)
+    worker = get_with_storage_celery_worker(celery_app)
 
     def sleep_for(seconds: float) -> None:
         time.sleep(seconds)

services/storage/tests/unit/test_rpc_handlers_simcore_s3.py

@@ -107,7 +107,7 @@ async def test_copy_folders_from_non_existing_project(
     product_name: ProductName,
     create_project: Callable[..., Awaitable[dict[str, Any]]],
     faker: Faker,
-    celery_worker: CeleryTaskQueueWorker,
+    with_storage_celery_worker: CeleryTaskQueueWorker,
 ):
     src_project = await create_project()
     incorrect_src_project = deepcopy(src_project)
@@ -148,7 +148,7 @@ async def test_copy_folders_from_empty_project(
     product_name: ProductName,
     create_project: Callable[[], Awaitable[dict[str, Any]]],
     sqlalchemy_async_engine: AsyncEngine,
-    celery_worker: CeleryTaskQueueWorker,
+    with_storage_celery_worker: CeleryTaskQueueWorker,
 ):
     # we will copy from src to dst
     src_project = await create_project()