From 49471192bd0529bc4e2a9dd131cd13a2f4f85f27 Mon Sep 17 00:00:00 2001
From: Rhys Arkins <rhys@arkins.net>
Date: Sat, 14 Mar 2020 06:12:29 +0100
Subject: [PATCH] =?UTF-8?q?fix:=20don=E2=80=99t=20do=20sequential=20packag?=
=?UTF-8?q?e=20fetching?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
lib/workers/repository/process/fetch.ts | 39 ++++++-------------------
1 file changed, 9 insertions(+), 30 deletions(-)
diff --git a/lib/workers/repository/process/fetch.ts b/lib/workers/repository/process/fetch.ts
index 5fb92864d2..bb445a933c 100644
--- a/lib/workers/repository/process/fetch.ts
+++ b/lib/workers/repository/process/fetch.ts
@@ -88,36 +88,15 @@ async function fetchManagerPackagerFileUpdates(
const { packageFile } = pFile;
const packageFileConfig = mergeChildConfig(managerConfig, pFile);
const { manager } = packageFileConfig;
- const problematicManagers = ['bundler', 'pip_requirements', 'maven'];
- if (problematicManagers.includes(manager)) {
- logger.debug(
- { manager, packageFile, queueLength: pFile.deps.length },
- 'fetchManagerPackagerFileUpdates starting sequentially'
- );
- for (const dep of pFile.deps) {
- const logMeta = { manager, packageFile, dependency: dep.depName };
- try {
- logger.debug(logMeta, 'fetchDepUpdates next');
- await fetchDepUpdates(packageFileConfig, dep);
- logger.debug(logMeta, 'fetchDepUpdates done');
- } catch (err) /* istanbul ignore next */ {
- logger.warn(
- { manager, packageFile, dependency: dep.depName, err },
- 'fetchDepUpdates error'
- );
- }
- }
- } else {
- const queue = pFile.deps.map(dep => (): Promise<void> =>
- fetchDepUpdates(packageFileConfig, dep)
- );
- logger.debug(
- { manager, packageFile, queueLength: queue.length },
- 'fetchManagerPackagerFileUpdates starting with concurrency'
- );
- await pAll(queue, { concurrency: 5 });
- }
- logger.debug({ packageFile }, 'fetchManagerPackagerFileUpdates finished');
+ const queue = pFile.deps.map(dep => (): Promise<void> =>
+ fetchDepUpdates(packageFileConfig, dep)
+ );
+ logger.trace(
+ { manager, packageFile, queueLength: queue.length },
+ 'fetchManagerPackagerFileUpdates starting with concurrency'
+ );
+ await pAll(queue, { concurrency: 5 });
+ logger.trace({ packageFile }, 'fetchManagerPackagerFileUpdates finished');
}
async function fetchManagerUpdates(
--
GitLab