File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed
services/dask-sidecar/src/simcore_service_dask_sidecar Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -82,10 +82,10 @@ async def _write_input_data(
8282
8383 destination_path = task_volumes .inputs_folder / file_name
8484
85- need_extraction = check_need_unzipping (
85+ need_unzipping = check_need_unzipping (
8686 input_params .url , input_params .file_mime_type , destination_path
8787 )
88- if input_params .file_mapping and need_extraction :
88+ if input_params .file_mapping and need_unzipping :
8989 raise ServiceInputsUseFileToKeyMapButReceivesZipDataError (
9090 service_key = self .task_parameters .image ,
9191 service_version = self .task_parameters .tag ,
Original file line number Diff line number Diff line change @@ -177,9 +177,9 @@ async def pull_file_from_remote(
177177 if s3_settings and src_url .scheme in S3_FILE_SYSTEM_SCHEMES :
178178 storage_kwargs = _s3fs_settings_from_s3_settings (s3_settings )
179179
180- need_extraction = check_need_unzipping (src_url , target_mime_type , dst_path )
180+ need_unzipping = check_need_unzipping (src_url , target_mime_type , dst_path )
181181 async with AsyncExitStack () as exit_stack :
182- if need_extraction :
182+ if need_unzipping :
183183 # we need to extract the file, so we create a temporary directory
184184 # where the file will be downloaded and extracted
185185 tmp_dir = await exit_stack .enter_async_context (
@@ -203,7 +203,7 @@ async def pull_file_from_remote(
203203 logging .INFO ,
204204 )
205205
206- if need_extraction :
206+ if need_unzipping :
207207 await log_publishing_cb (
208208 f"Uncompressing '{ download_dst_path .name } '..." , logging .INFO
209209 )
You can’t perform that action at this time.
0 commit comments