fix

CrowdDotDev · Nov 10, 2024 · 877368b · 877368b
1 parent 3788cc0
commit 877368b
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/services/apps/premium/members_enrichment_worker/src/activities/getMembers.ts b/services/apps/premium/members_enrichment_worker/src/activities/getMembers.ts
@@ -39,9 +39,16 @@ export async function getMaxConcurrentRequests(
 ): Promise<number> {
   const serviceMap: Partial<Record<MemberEnrichmentSource, IEnrichmentService>> = {}
   const distinctEnrichableSources = new Set<MemberEnrichmentSource>()
+  let maxConcurrentRequestsInAllSources = 0
 
   for (const source of possibleSources) {
     serviceMap[source] = EnrichmentSourceServiceFactory.getEnrichmentSourceService(source, svc.log)
+    if (serviceMap[source].maxConcurrentRequests > maxConcurrentRequestsInAllSources) {
+      maxConcurrentRequestsInAllSources = Math.max(
+        maxConcurrentRequestsInAllSources,
+        serviceMap[source].maxConcurrentRequests,
+      )
+    }
   }
   for (const member of members) {
     const enrichmentInput = await getEnrichmentInput(member)
@@ -57,7 +64,7 @@ export async function getMaxConcurrentRequests(
     })
   }
 
-  let smallestMaxConcurrentRequests = Infinity
+  let smallestMaxConcurrentRequests = maxConcurrentRequestsInAllSources
 
   Array.from(distinctEnrichableSources).forEach(async (source) => {
     smallestMaxConcurrentRequests = Math.min(