remove duplicate

Author: giancarloromeo

packages/celery-library/src/celery_library/models.py

@@ -87,6 +87,3 @@ class TaskStatus(BaseModel):
     @property
     def is_done(self) -> bool:
         return self.task_state in _TASK_DONE
-
-
-TaskId: TypeAlias = str

packages/celery-library/src/celery_library/task.py

@@ -17,7 +17,7 @@
 
 from . import get_event_loop
 from .errors import encore_celery_transferrable_error
-from .models import TaskID, TaskId
+from .models import TaskID
 from .utils import get_fastapi_app
 
 _logger = logging.getLogger(__name__)
@@ -145,7 +145,7 @@ def wrapper(task: AbortableTask, *args: P.args, **kwargs: P.kwargs) -> R:
 @overload
 def register_task(
     app: Celery,
-    fn: Callable[Concatenate[AbortableTask, TaskId, P], Coroutine[Any, Any, R]],
+    fn: Callable[Concatenate[AbortableTask, TaskID, P], Coroutine[Any, Any, R]],
     task_name: str | None = None,
     timeout: timedelta | None = _DEFAULT_TASK_TIMEOUT,
     max_retries: NonNegativeInt = _DEFAULT_MAX_RETRIES,
@@ -169,7 +169,7 @@ def register_task(
 def register_task(  # type: ignore[misc]
     app: Celery,
     fn: (
-        Callable[Concatenate[AbortableTask, TaskId, P], Coroutine[Any, Any, R]]
+        Callable[Concatenate[AbortableTask, TaskID, P], Coroutine[Any, Any, R]]
         | Callable[Concatenate[AbortableTask, P], R]
     ),
     task_name: str | None = None,

services/storage/src/simcore_service_storage/api/_worker_tasks/_files.py

@@ -1,7 +1,7 @@
 import logging
 
 from celery import Task  # type: ignore[import-untyped]
-from celery_library.models import TaskId
+from celery_library.models import TaskID
 from celery_library.utils import get_fastapi_app
 from models_library.api_schemas_storage.storage_schemas import (
     FileUploadCompletionBody,
@@ -18,7 +18,7 @@
 
 async def complete_upload_file(
     task: Task,
-    task_id: TaskId,
+    task_id: TaskID,
     user_id: UserID,
     location_id: LocationID,
     file_id: StorageFileID,

services/storage/src/simcore_service_storage/api/_worker_tasks/_paths.py

@@ -2,7 +2,7 @@
 from pathlib import Path
 
 from celery import Task  # type: ignore[import-untyped]
-from celery_library.models import TaskId
+from celery_library.models import TaskID
 from celery_library.utils import get_fastapi_app
 from models_library.projects_nodes_io import LocationID, StorageFileID
 from models_library.users import UserID
@@ -17,7 +17,7 @@
 
 
 async def compute_path_size(
-    task: Task, task_id: TaskId, user_id: UserID, location_id: LocationID, path: Path
+    task: Task, task_id: TaskID, user_id: UserID, location_id: LocationID, path: Path
 ) -> ByteSize:
     assert task_id  # nosec
     with log_context(
@@ -31,7 +31,7 @@ async def compute_path_size(
 
 async def delete_paths(
     task: Task,
-    task_id: TaskId,
+    task_id: TaskID,
     user_id: UserID,
     location_id: LocationID,
     paths: set[Path],

services/storage/src/simcore_service_storage/api/_worker_tasks/_simcore_s3.py

@@ -4,7 +4,7 @@
 
 from aws_library.s3._models import S3ObjectKey
 from celery import Task  # type: ignore[import-untyped]
-from celery_library.models import TaskID, TaskId
+from celery_library.models import TaskID
 from celery_library.utils import get_celery_worker, get_fastapi_app
 from models_library.api_schemas_storage.storage_schemas import FoldersBody
 from models_library.api_schemas_webserver.storage import PathToExport
@@ -22,7 +22,7 @@
 
 
 async def _task_progress_cb(
-    task: Task, task_id: TaskId, report: ProgressReport
+    task: Task, task_id: TaskID, report: ProgressReport
 ) -> None:
     worker = get_celery_worker(task.app)
     assert task.name  # nosec
@@ -33,7 +33,7 @@ async def _task_progress_cb(
 
 
 async def deep_copy_files_from_project(
-    task: Task, task_id: TaskId, user_id: UserID, body: FoldersBody
+    task: Task, task_id: TaskID, user_id: UserID, body: FoldersBody
 ) -> dict[str, Any]:
     with log_context(
         _logger,