|
14 | 14 | from fastapi_pagination.api import create_page |
15 | 15 | from models_library.api_schemas_storage import ETag, FileUploadCompletionBody, LinkType |
16 | 16 | from models_library.basic_types import SHA256Str |
17 | | -from pydantic import AnyUrl, ByteSize, PositiveInt, ValidationError, parse_obj_as |
| 17 | +from pydantic import AnyUrl, ByteSize, PositiveInt, TypeAdapter, ValidationError |
18 | 18 | from servicelib.fastapi.requests_decorators import cancel_on_disconnect |
19 | 19 | from simcore_sdk.node_ports_common.constants import SIMCORE_LOCATION |
20 | 20 | from simcore_sdk.node_ports_common.file_io_utils import UploadableFileObject |
@@ -360,7 +360,7 @@ async def abort_multipart_upload( |
360 | 360 | abort_link: URL = await storage_client.create_abort_upload_link( |
361 | 361 | file=file, query={"user_id": str(user_id)} |
362 | 362 | ) |
363 | | - await abort_upload(abort_upload_link=parse_obj_as(AnyUrl, str(abort_link))) |
| 363 | + await abort_upload(abort_upload_link=TypeAdapter(AnyUrl).validate_python(str(abort_link))) |
364 | 364 |
|
365 | 365 |
|
366 | 366 | @router.post( |
@@ -392,7 +392,7 @@ async def complete_multipart_upload( |
392 | 392 |
|
393 | 393 | e_tag: ETag = await complete_file_upload( |
394 | 394 | uploaded_parts=uploaded_parts.parts, |
395 | | - upload_completion_link=parse_obj_as(AnyUrl, f"{complete_link}"), |
| 395 | + upload_completion_link=TypeAdapter(AnyUrl).validate_python(f"{complete_link}"), |
396 | 396 | ) |
397 | 397 |
|
398 | 398 | file.e_tag = e_tag |
|
0 commit comments