further name changes zipping -> data_export

Author: bisgaard-itis

packages/models-library/src/models_library/api_schemas_storage/zipping_tasks.py renamed to packages/models-library/src/models_library/api_schemas_storage/data_export_tasks.py

@@ -5,10 +5,10 @@
 from pydantic import BaseModel, Field
 
 
-class ZipTaskStartInput(BaseModel):
+class DataExportTaskStartInput(BaseModel):
     paths: list[Path] = Field(..., min_length=1)
 
 
-class ZipTaskAbortOutput(BaseModel):
+class DataExportTaskAbortOutput(BaseModel):
     result: bool
     task_id: TaskRpcId

packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/storage/data_export.py

@@ -7,9 +7,9 @@
     TaskRpcStatus,
 )
 from models_library.api_schemas_storage import STORAGE_RPC_NAMESPACE
-from models_library.api_schemas_storage.zipping_tasks import (
-    ZipTaskAbortOutput,
-    ZipTaskStartInput,
+from models_library.api_schemas_storage.data_export_tasks import (
+    DataExportTaskAbortOutput,
+    DataExportTaskStartInput,
 )
 from models_library.rabbitmq_basic_types import RPCMethodName
 from pydantic import NonNegativeInt, TypeAdapter
@@ -22,7 +22,7 @@
 
 
 async def start_data_export(
-    rabbitmq_rpc_client: RabbitMQRPCClient, *, paths: ZipTaskStartInput
+    rabbitmq_rpc_client: RabbitMQRPCClient, *, paths: DataExportTaskStartInput
 ) -> TaskRpcGet:
     result = await rabbitmq_rpc_client.request(
         STORAGE_RPC_NAMESPACE,
@@ -36,14 +36,14 @@ async def start_data_export(
 
 async def abort_data_export(
     rabbitmq_rpc_client: RabbitMQRPCClient, *, task_id: TaskRpcId
-) -> ZipTaskAbortOutput:
+) -> DataExportTaskAbortOutput:
     result = await rabbitmq_rpc_client.request(
         STORAGE_RPC_NAMESPACE,
         _RPC_METHOD_NAME_ADAPTER.validate_python("abort_data_export"),
         task_id=task_id,
         timeout_s=_DEFAULT_TIMEOUT_S,
     )
-    assert isinstance(result, ZipTaskAbortOutput)
+    assert isinstance(result, DataExportTaskAbortOutput)
     return result
 
 

services/storage/src/simcore_service_storage/api/rpc/_data_export.py

@@ -8,17 +8,19 @@
     TaskRpcResult,
     TaskRpcStatus,
 )
-from models_library.api_schemas_storage.zipping_tasks import (
-    ZipTaskAbortOutput,
-    ZipTaskStartInput,
+from models_library.api_schemas_storage.data_export_tasks import (
+    DataExportTaskAbortOutput,
+    DataExportTaskStartInput,
 )
 from servicelib.rabbitmq import RPCRouter
 
 router = RPCRouter()
 
 
 @router.expose()
-async def start_data_export(app: FastAPI, paths: ZipTaskStartInput) -> TaskRpcGet:
+async def start_data_export(
+    app: FastAPI, paths: DataExportTaskStartInput
+) -> TaskRpcGet:
     assert app  # nosec
     return TaskRpcGet(
         task_id=uuid4(),
@@ -27,9 +29,11 @@ async def start_data_export(app: FastAPI, paths: ZipTaskStartInput) -> TaskRpcGe
 
 
 @router.expose()
-async def abort_data_export(app: FastAPI, task_id: TaskRpcId) -> ZipTaskAbortOutput:
+async def abort_data_export(
+    app: FastAPI, task_id: TaskRpcId
+) -> DataExportTaskAbortOutput:
     assert app  # nosec
-    return ZipTaskAbortOutput(result=True, task_id=task_id)
+    return DataExportTaskAbortOutput(result=True, task_id=task_id)
 
 
 @router.expose()

services/storage/tests/unit/test_data_export.py

@@ -12,9 +12,9 @@
     TaskRpcResult,
     TaskRpcStatus,
 )
-from models_library.api_schemas_storage.zipping_tasks import (
-    ZipTaskAbortOutput,
-    ZipTaskStartInput,
+from models_library.api_schemas_storage.data_export_tasks import (
+    DataExportTaskAbortOutput,
+    DataExportTaskStartInput,
 )
 from pytest_mock import MockerFixture
 from pytest_simcore.helpers.monkeypatch_envs import setenvs_from_dict
@@ -75,15 +75,15 @@ async def rpc_client(
 
 async def test_start_data_export(rpc_client: RabbitMQRPCClient, faker: Faker):
     result = await data_export.start_data_export(
-        rpc_client, paths=ZipTaskStartInput(paths=[Path(faker.file_path())])
+        rpc_client, paths=DataExportTaskStartInput(paths=[Path(faker.file_path())])
     )
     assert isinstance(result, TaskRpcGet)
 
 
 async def test_abort_data_export(rpc_client: RabbitMQRPCClient, faker: Faker):
     _task_id = TaskRpcId(faker.uuid4())
     result = await data_export.abort_data_export(rpc_client, task_id=_task_id)
-    assert isinstance(result, ZipTaskAbortOutput)
+    assert isinstance(result, DataExportTaskAbortOutput)
     assert result.task_id == _task_id