Stop applying concurrency limits. We want to merge the extra tests

src/plugins/usage_collection/server/collector/collector_set.ts

@@ -5,7 +5,7 @@
  * in compliance with, at your election, the Elastic License 2.0 or the Server
  * Side Public License, v 1.
  */
-import { withTimeout, asyncMapWithLimit } from '@kbn/std';
+import { withTimeout } from '@kbn/std';
 import { snakeCase } from 'lodash';
 
 import type {
@@ -42,21 +42,18 @@ export interface CollectorSetConfig {
 export class CollectorSet {
   private readonly logger: Logger;
   private readonly executionContext: ExecutionContextSetup;
-  private readonly collectorsFetchConcurrency: number;
   private readonly maximumWaitTimeForAllCollectorsInS: number;
   private readonly collectors: Map<string, AnyCollector>;
   constructor({
     logger,
     executionContext,
-    collectorsFetchConcurrency = Infinity,
     maximumWaitTimeForAllCollectorsInS = DEFAULT_MAXIMUM_WAIT_TIME_FOR_ALL_COLLECTORS_IN_S,
     collectors = [],
   }: CollectorSetConfig) {
     this.logger = logger;
     this.executionContext = executionContext;
     this.collectors = new Map(collectors.map((collector) => [collector.type, collector]));
     this.maximumWaitTimeForAllCollectorsInS = maximumWaitTimeForAllCollectorsInS;
-    this.collectorsFetchConcurrency = collectorsFetchConcurrency;
   }
 
   /**
@@ -233,17 +230,15 @@ export class CollectorSet {
     // freeze object to prevent collectors from mutating it.
     const context = Object.freeze({ esClient, soClient });
 
-    const fetchExecutions = await asyncMapWithLimit(
-      readyCollectors,
-      this.collectorsFetchConcurrency,
-      async (collector) => {
+    const fetchExecutions = await Promise.all(
+      readyCollectors.map(async (collector) => {
         const wrappedPromise = perfTimerify(
           `fetch_${collector.type}`,
           async () => await this.fetchCollector(collector, context)
         );
 
         return await wrappedPromise();
-      }
+      })
     );
     const durationMarks = getMarks();
 
@@ -365,7 +360,6 @@ export class CollectorSet {
       logger: this.logger,
       executionContext: this.executionContext,
       maximumWaitTimeForAllCollectorsInS: this.maximumWaitTimeForAllCollectorsInS,
-      collectorsFetchConcurrency: this.collectorsFetchConcurrency,
       collectors,
     });
   };

src/plugins/usage_collection/server/config.ts

@@ -23,7 +23,6 @@ export const configSchema = schema.object({
   maximumWaitTimeForAllCollectorsInS: schema.number({
     defaultValue: DEFAULT_MAXIMUM_WAIT_TIME_FOR_ALL_COLLECTORS_IN_S,
   }),
-  collectorsFetchConcurrency: schema.number({ defaultValue: 5 }),
 });
 
 export type ConfigType = TypeOf<typeof configSchema>;