From 7be68d9448d2f1dcbaa4a1ca0ab980a2b62db841 Mon Sep 17 00:00:00 2001 From: Casper da Costa-Luis Date: Wed, 28 Aug 2019 17:58:53 +0100 Subject: [PATCH] replace md5 => file --- dvc/remote/base.py | 6 +++--- dvc/remote/local/__init__.py | 2 +- dvc/remote/ssh/__init__.py | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/dvc/remote/base.py b/dvc/remote/base.py index 2fbf79885..9efd0180e 100644 --- a/dvc/remote/base.py +++ b/dvc/remote/base.py @@ -650,16 +650,16 @@ class RemoteBASE(object): desc="Querying " + ("cache in " + name if name else "remote cache"), total=len(checksums), - unit="md5", + unit="file", ) as pbar: def exists_with_progress(path_info): ret = self.exists(path_info) - pbar.update() + pbar.update_desc(str(path_info)) return ret with ThreadPoolExecutor(max_workers=jobs or self.JOBS) as executor: - path_infos = [self.checksum_to_path_info(x) for x in checksums] + path_infos = map(self.checksum_to_path_info, checksums) in_remote = executor.map(exists_with_progress, path_infos) ret = list(itertools.compress(checksums, in_remote)) return ret diff --git a/dvc/remote/local/__init__.py b/dvc/remote/local/__init__.py index 5bba17b6a..0a0a4b84d 100644 --- a/dvc/remote/local/__init__.py +++ b/dvc/remote/local/__init__.py @@ -252,7 +252,7 @@ class RemoteLOCAL(RemoteBASE): checksum for checksum in Tqdm( checksums, - unit="md5", + unit="file", desc="Querying " + ("cache in " + name if name else "local cache"), ) diff --git a/dvc/remote/ssh/__init__.py b/dvc/remote/ssh/__init__.py index 5c243f471..74280d7bb 100644 --- a/dvc/remote/ssh/__init__.py +++ b/dvc/remote/ssh/__init__.py @@ -271,7 +271,7 @@ class RemoteSSH(RemoteBASE): desc="Querying " + ("cache in " + name if name else "remote cache"), total=len(checksums), - unit="md5", + unit="file", ) as pbar: def exists_with_progress(chunks):