From 68a2f34a469b3facaccb388fc25499bfa8c5a4f2 Mon Sep 17 00:00:00 2001 From: Casper da Costa-Luis Date: Wed, 26 Feb 2020 20:35:19 +0000 Subject: [PATCH] pull: fetch: external: respect jobs (#3413) 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 e995630e4..ab6e178d8 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: