build

server/pipelines/tasks/__init__.py

@@ -147,7 +147,7 @@ def celery_task(func: TaskFunction[T]) -> SubmitFunction[T]:
         logger.info('Queueing task for celery...')
         app_task.delay(task_id, *args, **kwargs)
 
-    return submit
+    return submit  # type: ignore[return-value]  # FIXME
 
 
 # # Import the module

server/pipelines/tasks/imports.py

@@ -17,7 +17,7 @@ from server.util.config import settings, conf_file
 from . import TaskContext, celery_task, unpack_context
 
 
-@celery_task
+@celery_task  # type: ignore[arg-type]
 async def submit_import_task(ctx: TaskContext, import_id: str | None = None) -> None:  # type: ignore[arg-type] #FIXME
     session, target_dir, logger, work_dir, task, celery = unpack_context(ctx, __name__)
     logger.info('Preparing import task!')