|
17 | 17 | import httpx |
18 | 18 | import pytest |
19 | 19 | import sqlalchemy as sa |
20 | | -from aws_library.s3 import SimcoreS3API |
21 | 20 | from faker import Faker |
22 | 21 | from fastapi import FastAPI |
23 | 22 | from fastapi.encoders import jsonable_encoder |
|
52 | 51 | copy_folders_from_project, |
53 | 52 | ) |
54 | 53 | from simcore_postgres_database.storage_models import file_meta_data |
| 54 | +from simcore_service_storage.modules.celery.worker import CeleryTaskQueueWorker |
55 | 55 | from simcore_service_storage.simcore_s3_dsm import SimcoreS3DataManager |
56 | 56 | from sqlalchemy.ext.asyncio import AsyncEngine |
57 | 57 | from yarl import URL |
@@ -107,6 +107,7 @@ async def test_copy_folders_from_non_existing_project( |
107 | 107 | product_name: ProductName, |
108 | 108 | create_project: Callable[..., Awaitable[dict[str, Any]]], |
109 | 109 | faker: Faker, |
| 110 | + celery_worker: CeleryTaskQueueWorker, |
110 | 111 | ): |
111 | 112 | src_project = await create_project() |
112 | 113 | incorrect_src_project = deepcopy(src_project) |
@@ -147,7 +148,7 @@ async def test_copy_folders_from_empty_project( |
147 | 148 | product_name: ProductName, |
148 | 149 | create_project: Callable[[], Awaitable[dict[str, Any]]], |
149 | 150 | sqlalchemy_async_engine: AsyncEngine, |
150 | | - storage_s3_client: SimcoreS3API, |
| 151 | + celery_worker: CeleryTaskQueueWorker, |
151 | 152 | ): |
152 | 153 | # we will copy from src to dst |
153 | 154 | src_project = await create_project() |
|
0 commit comments