diff --git a/server/pipelines/tasks/__init__.py b/server/pipelines/tasks/__init__.py
index b6dc1d4c241a419954e903dd7614bf799f07d706..19b03a2b7882a8363f5af3c7aaad9244a5819851 100644
--- a/server/pipelines/tasks/__init__.py
+++ b/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
diff --git a/server/pipelines/tasks/imports.py b/server/pipelines/tasks/imports.py
index 0061c852412db6ab7d5cc047e3a2ecd4788ddd96..c8cf9f9f7f5ae5c5456bec1b99a6dea721d084ef 100644
--- a/server/pipelines/tasks/imports.py
+++ b/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!')