diff --git a/services/apps/premium/members_enrichment_worker/src/activities/getMembers.ts b/services/apps/premium/members_enrichment_worker/src/activities/getMembers.ts index b0d1677913..b0da58c2d1 100644 --- a/services/apps/premium/members_enrichment_worker/src/activities/getMembers.ts +++ b/services/apps/premium/members_enrichment_worker/src/activities/getMembers.ts @@ -6,8 +6,8 @@ import { svc } from '../main' getMembers is a Temporal activity that retrieves all members available for enrichment. Member must have one of GitHub username or email address, must not have been enriched in the past 90 days, and must be part of tenant with a plan -allowing this feature. We limit to 20 members per workflow to not overload -OpenSearch and external APIs. +allowing this feature. We limit to 10 members per workflow to not overload +OpenSearch and external APIs, but mostly to not exceed Temporal result size limit. */ export async function getMembers(): Promise { let rows: IMember[] = [] @@ -29,7 +29,7 @@ export async function getMembers(): Promise { INNER JOIN tenants ON tenants.id = members."tenantId" INNER JOIN "memberIdentities" mi ON mi."memberId" = members.id INNER JOIN activities ON activities."memberId" = members.id - WHERE tenants.plan IN ('Scale', 'Enterprise') + WHERE tenants.plan IN ('Growth', 'Scale', 'Enterprise') AND ( members."lastEnriched" < NOW() - INTERVAL '90 days' OR members."lastEnriched" IS NULL @@ -42,7 +42,7 @@ export async function getMembers(): Promise { AND members."deletedAt" IS NULL GROUP BY members.id ORDER BY activity_count DESC - LIMIT 20;`, + LIMIT 10;`, ) } catch (err) { throw new Error(err)