name

Author: giancarloromeo

services/storage/src/simcore_service_storage/api/rpc/_data_export.py

@@ -63,7 +63,7 @@ async def start_data_export(
             task_context=job_id_data.model_dump(),
             task_metadata=TaskMetadata(
                 ephemeral=False,
-                queue=TasksQueue.CPU_BOUND.name.lower(),
+                queue=TasksQueue.CPU_BOUND,
             ),
             files=data_export_start.file_and_folder_ids,  # ANE: adapt here your signature
         )

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

@@ -34,13 +34,13 @@ class TaskState(StrEnum):
 
 
 class TasksQueue(StrEnum):
-    CPU_BOUND = auto()
-    DEFAULT = auto()
+    CPU_BOUND = "cpu_bound"
+    DEFAULT = "default"
 
 
 class TaskMetadata(BaseModel):
     ephemeral: bool = True
-    queue: str = "default"
+    queue: TasksQueue = TasksQueue.DEFAULT
 
 
 _TASK_DONE = {TaskState.SUCCESS, TaskState.ERROR, TaskState.ABORTED}