further cleanup of ProgressReport

Author: bisgaard-itis

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

@@ -36,7 +36,7 @@
 _CELERY_TASK_ID_KEY_ENCODING = "utf-8"
 
 _MIN_PROGRESS_VALUE = 0.0
-_MAX_PROGRESS_VALUE = 100.0
+_MAX_PROGRESS_VALUE = 1.0
 
 
 def _build_context_prefix(task_context: TaskContext) -> list[str]:
@@ -99,8 +99,12 @@ def _get_progress_report(
             TaskState.ERROR,
             TaskState.SUCCESS,
         ):
-            return ProgressReport(actual_value=_MAX_PROGRESS_VALUE)
-        return ProgressReport(actual_value=_MIN_PROGRESS_VALUE)
+            return ProgressReport(
+                actual_value=_MAX_PROGRESS_VALUE, total=_MAX_PROGRESS_VALUE
+            )
+        return ProgressReport(
+            actual_value=_MIN_PROGRESS_VALUE, total=_MAX_PROGRESS_VALUE
+        )
 
     def _get_state(self, task_context: TaskContext, task_uuid: TaskUUID) -> TaskState:
         task_id = _build_task_id(task_context, task_uuid)

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

@@ -13,6 +13,7 @@
 
 def export_data(task: Task, files: list[StorageFileID]):
     _logger.info("Exporting files: %s", files)
+    assert len(files) > 0
     for n, file in enumerate(files, start=1):
         with log_context(
             _logger,
@@ -23,7 +24,7 @@ def export_data(task: Task, files: list[StorageFileID]):
             get_celery_worker(task.app).set_task_progress(
                 task_name=task.name,
                 task_id=task.request.id,
-                report=ProgressReport(actual_value=n / len(files) * 100),
+                report=ProgressReport(actual_value=n, total=len(files)),
             )
             time.sleep(10)
     return "done"