diff --git a/dvc/remote/local.py b/dvc/remote/local.py
index b778ff46c6..9e6b7b6a2e 100644
--- a/dvc/remote/local.py
+++ b/dvc/remote/local.py
@@ -626,8 +626,12 @@ def _process(
             func = pbar.wrap_fn(func)
             with ThreadPoolExecutor(max_workers=jobs) as executor:
                 if download:
-                    fails = sum(executor.map(func, *dir_plans))
-                    fails += sum(executor.map(func, *file_plans))
+                    from_infos, to_infos, names, _ = (
+                        d + f for d, f in zip(dir_plans, file_plans)
+                    )
+                    fails = sum(
+                        executor.map(func, from_infos, to_infos, names)
+                    )
                 else:
                     # for uploads, push files first, and any .dir files last