typecheck

Author: giancarloromeo

services/storage/src/simcore_service_storage/modules/celery/_common.py

@@ -4,9 +4,9 @@
 import traceback
 from typing import Any
 
-from celery import Celery, Task
-from celery.exceptions import Ignore
-from celery.contrib.abortable import AbortableTask
+from celery import Celery, Task # type: ignore[import-untyped]
+from celery.exceptions import Ignore    # type: ignore[import-untyped]
+from celery.contrib.abortable import AbortableTask  # type: ignore[import-untyped]
 from settings_library.celery import CelerySettings
 from settings_library.redis import RedisDatabase
 

services/storage/src/simcore_service_storage/modules/celery/client.py

@@ -3,8 +3,8 @@
 from typing import Any, Final
 from uuid import uuid4
 
-from celery import Celery
-from celery.contrib.abortable import AbortableAsyncResult
+from celery import Celery   # type: ignore[import-untyped]
+from celery.contrib.abortable import AbortableAsyncResult   # type: ignore[import-untyped]
 from common_library.async_tools import make_async
 from models_library.progress_bar import ProgressReport
 from pydantic import ValidationError

services/storage/src/simcore_service_storage/modules/celery/signals.py

@@ -4,7 +4,7 @@
 from typing import Final
 
 from asgi_lifespan import LifespanManager
-from celery import Celery
+from celery import Celery   # type: ignore[import-untyped]
 from fastapi import FastAPI
 from servicelib.async_utils import cancel_wait_task
 from ...core.application import create_app

services/storage/src/simcore_service_storage/modules/celery/tasks.py

@@ -2,7 +2,7 @@
 import time
 
 
-from celery import Task
+from celery import Task # type: ignore[import-untyped]
 from models_library.progress_bar import ProgressReport
 from models_library.projects_nodes_io import StorageFileID
 from servicelib.logging_utils import log_context

services/storage/src/simcore_service_storage/modules/celery/utils.py

@@ -1,4 +1,4 @@
-from celery import Celery
+from celery import Celery   # type: ignore[import-untyped]
 from fastapi import FastAPI
 
 from .worker import CeleryTaskQueueWorker

services/storage/src/simcore_service_storage/modules/celery/worker.py

@@ -1,6 +1,6 @@
 import logging
 
-from celery import Celery
+from celery import Celery   # type: ignore[import-untyped]
 from models_library.progress_bar import ProgressReport
 from servicelib.logging_utils import log_context
 

services/storage/src/simcore_service_storage/modules/celery/worker_main.py

@@ -2,7 +2,7 @@
 
 import logging
 
-from celery.signals import worker_init, worker_shutdown
+from celery.signals import worker_init, worker_shutdown # type: ignore[import-untyped]
 from servicelib.logging_utils import config_all_loggers
 from simcore_service_storage.modules.celery.signals import (
     on_worker_init,