uj&ddlZddlmZmZddZdS)N)ThreadPoolExecutor as_completeditemc  g}g}t|5 fd|D}t|D]{}|\}} } | r0||| ft d|d|d| L||| ft d|d|d| | dddn #1swxYwYt d t |d t |d |rDt d |d |D]\}} t d|d| t jd||fS)aDownload multiple items concurrently with progress reporting. Args: download_fn: Callable that takes an item and returns (identifier, result_path, error_string_or_None). items: List of items to download. max_workers (int): Maximum concurrent workers. item_name (str): Display name for the item type. Returns: tuple: (succeeded_list, failed_list). ) max_workersc>i|]}||S)submit).0r download_fnexecutors d/lsinfo/ai/hellotax_ai/data_center/backend/venv/lib/python3.11/site-packages/modelscope/cli/utils.py z'concurrent_download..s)NNN8??;55tNNNzFailed to download  z: z Downloaded z -> Nz Download complete: z succeeded, z failedzFailed zs:z )rrresultappendprintlensysexit) r itemsr item_name succeededfailedfuturesfuture identifier result_patherrorrs ` @rconcurrent_downloadr#sI F  4 4 4 ONNNNNNNN"7++ O OF-3]]__ *J U O z51222MIMM MMeMMNNNN  *k!:;;;MIMM MM MMNNNN O O O O O O O O O O O O O O O O  "#i.. " " [[ " " "###  % %%%&&&!' . . J ,z,,U,, - - - -  f sBB??CC)rr)rconcurrent.futuresrrr#r rrr%sD ????????######r