def METHOD_NAME(
    tmp_path: Path, manager: storage.SharedFSStorageManager
) -> None:
    with parallel.Execution(4, local_size=2) as pex:
        @pex.run
        def do_test() -> None:
            util.run_storage_upload_download_sharded_test(pex, manager, tmp_path, clean_up)