From 377230f9a6c1c2c9cbec5dd995e57b08a584061c Mon Sep 17 00:00:00 2001 From: Casper da Costa-Luis Date: Wed, 26 Feb 2020 16:19:30 +0000 Subject: [PATCH] pull: fetch: external: respect jobs Fixes #3396 --- dvc/repo/fetch.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dvc/repo/fetch.py b/dvc/repo/fetch.py index e995630e41..ab6e178d8c 100644 --- a/dvc/repo/fetch.py +++ b/dvc/repo/fetch.py @@ -58,7 +58,7 @@ def _fetch( failed += exc.amount for (repo_url, repo_rev), files in used.external.items(): - d, f = _fetch_external(self, repo_url, repo_rev, files) + d, f = _fetch_external(self, repo_url, repo_rev, files, jobs) downloaded += d failed += f @@ -68,7 +68,7 @@ def _fetch( return downloaded -def _fetch_external(self, repo_url, repo_rev, files): +def _fetch_external(self, repo_url, repo_rev, files, jobs): from dvc.external_repo import external_repo failed = 0 @@ -91,7 +91,7 @@ def _fetch_external(self, repo_url, repo_rev, files): cache.update(out.get_used_cache()) try: - return repo.cloud.pull(cache), failed + return repo.cloud.pull(cache, jobs=jobs), failed except DownloadError as exc: failed += exc.amount except CloneError: