fix test_start_export_data

Author: giancarloromeo

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

@@ -68,7 +68,7 @@ async def send_task(
                 task_name,
                 task_id=task_id,
                 kwargs=task_params,
-                queue=task_metadata.queue,
+                queue=task_metadata.queue.value,
             )
 
             expiry = (
@@ -145,12 +145,12 @@ async def get_task_status(
             logging.DEBUG,
             msg=f"Getting task status: {task_context=} {task_uuid=}",
         ):
-            state = await self._get_state(task_context, task_uuid)
+            task_state = await self._get_state(task_context, task_uuid)
             result = await self._get_result(task_context, task_uuid)
             return TaskStatus(
                 task_uuid=task_uuid,
-                task_state=state,
-                progress_report=await self._get_progress_report(state, result),
+                task_state=task_state,
+                progress_report=await self._get_progress_report(task_state, result),
             )
 
     async def get_task_uuids(self, task_context: TaskContext) -> set[TaskUUID]:

services/storage/tests/conftest.py

@@ -1016,7 +1016,7 @@ async def with_storage_celery_worker_controller(
         concurrency=1,
         loglevel="info",
         perform_ping_check=False,
-        worker_kwargs={"hostname": "celery@worker1"},
+        queues="default,cpu_bound",
     ) as worker:
         worker_init.send(sender=worker)