|
33 | 33 | ) |
34 | 34 | from servicelib.rabbitmq.rpc_interfaces.storage.paths import ( |
35 | 35 | compute_path_size, |
36 | | - delete_paths, |
37 | 36 | ) |
38 | 37 | from simcore_service_storage.modules.celery.worker import CeleryTaskQueueWorker |
39 | 38 | from simcore_service_storage.simcore_s3_dsm import SimcoreS3DataManager |
@@ -96,39 +95,6 @@ async def _assert_compute_path_size( |
96 | 95 | pytest.fail("Job did not finish") |
97 | 96 |
|
98 | 97 |
|
99 | | -async def _assert_delete_paths( |
100 | | - storage_rpc_client: RabbitMQRPCClient, |
101 | | - location_id: LocationID, |
102 | | - user_id: UserID, |
103 | | - product_name: ProductName, |
104 | | - *, |
105 | | - paths: set[Path], |
106 | | -) -> None: |
107 | | - async_job, async_job_name = await delete_paths( |
108 | | - storage_rpc_client, |
109 | | - product_name=product_name, |
110 | | - user_id=user_id, |
111 | | - location_id=location_id, |
112 | | - paths=paths, |
113 | | - ) |
114 | | - await asyncio.sleep(1) |
115 | | - async for job_composed_result in wait_and_get_result( |
116 | | - storage_rpc_client, |
117 | | - rpc_namespace=STORAGE_RPC_NAMESPACE, |
118 | | - method_name=RPCMethodName(compute_path_size.__name__), |
119 | | - job_id=async_job.job_id, |
120 | | - job_id_data=AsyncJobNameData(user_id=user_id, product_name=product_name), |
121 | | - client_timeout=datetime.timedelta(seconds=120), |
122 | | - ): |
123 | | - if job_composed_result.done: |
124 | | - response = await job_composed_result.result() |
125 | | - assert isinstance(response, AsyncJobResult) |
126 | | - assert response.result is None |
127 | | - return |
128 | | - |
129 | | - pytest.fail("Job did not finish") |
130 | | - |
131 | | - |
132 | 98 | @pytest.mark.parametrize( |
133 | 99 | "location_id", |
134 | 100 | [SimcoreS3DataManager.get_location_id()], |
|
0 commit comments