File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed
services/storage/src/simcore_service_storage Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -811,9 +811,9 @@ async def deep_copy_project_simcore_s3(
811811 limit = _MAX_PARALLEL_S3_CALLS ,
812812 )
813813 total_num_of_files = sum (n for _ , n in sizes_and_num_files )
814- src_project_total_data_size : ByteSize = TypeAdapter (
815- ByteSize
816- ). validate_python ( sum ( n for n , _ in sizes_and_num_files ))
814+ src_project_total_data_size = TypeAdapter ( ByteSize ). validate_python (
815+ sum ( n for n , _ in sizes_and_num_files )
816+ )
817817
818818 async with S3TransferDataCB (
819819 task_progress ,
Original file line number Diff line number Diff line change @@ -27,7 +27,7 @@ class S3TransferDataCB:
2727 def __post_init__ (self ) -> None :
2828 self ._async_update_periodic_task = create_periodic_task (
2929 self ._async_update ,
30- interval = datetime .timedelta (seconds = 1 ),
30+ interval = datetime .timedelta (seconds = 0.2 ),
3131 task_name = "s3_transfer_cb_update" ,
3232 )
3333 self ._update ()
@@ -48,7 +48,7 @@ async def _async_update(self) -> None:
4848 f"{ self .task_progress_message_prefix } - "
4949 f"{ self .total_bytes_to_transfer .human_readable ()} "
5050 )
51- await self .task_progress .update (
51+ await self .task_progress .set_ (
5252 min (self ._total_bytes_copied , self .total_bytes_to_transfer )
5353 / (self .total_bytes_to_transfer or 1 )
5454 )
You can’t perform that action at this time.
0 commit comments