Skip to content

Commit 90fd833

Browse files
committed
fix celery tests
1 parent 6864fe3 commit 90fd833

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ def export_data(task: Task, files: list[StorageFileID]):
2424
get_celery_worker(task.app).set_task_progress(
2525
task_name=task.name,
2626
task_id=task.request.id,
27-
report=ProgressReport(actual_value=n, total=len(files)),
27+
report=ProgressReport(actual_value=n / len(files), total=1),
2828
)
2929
time.sleep(10)
3030
return "done"

services/storage/tests/unit/modules/celery/test_celery.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ def sleep_for(seconds: float) -> None:
4141
worker.set_task_progress(
4242
task_name=task_name,
4343
task_id=task_id,
44-
report=ProgressReport(actual_value=n / len(files) * 10),
44+
report=ProgressReport(actual_value=n / len(files), total=1.0),
4545
)
4646
await asyncio.get_event_loop().run_in_executor(None, sleep_for, 1)
4747

0 commit comments

Comments
 (0)