(gcs_path_: epath.Path)
| 126 | ) as pbar: |
| 127 | |
| 128 | def _copy(gcs_path_: epath.Path): |
| 129 | # Copy 'gs://tfds-data/datasets/ds/1.0.0/file' -> `local_dir/file` |
| 130 | gcs_path_.copy(dst=os.path.join(local_folder, gcs_path_.name)) |
| 131 | pbar.update(1) |
| 132 | |
| 133 | with concurrent.futures.ThreadPoolExecutor( |
| 134 | max_workers=max_simultaneous_downloads |