fix: stabilize membersGlobalActivityCount mv refresh (CM-1302) (#4309)

Signed-off-by: Yeganathan S <63534555+skwowet@users.noreply.github.com>

Author: skwowet

backend/src/database/migrations/R__memberEnrichmentMaterializedViews.sql

@@ -10,8 +10,7 @@ where msa."segmentId" IN (
         where "grandparentId" is not null
             and "parentId" is not null
     )
-group by msa."memberId"
-order by sum(msa."activityCount") desc;
+group by msa."memberId";
 create unique index ix_member_global_activity_count_member_id on "membersGlobalActivityCount" ("memberId");
 create index ix_member_global_activity_count on "membersGlobalActivityCount" (total_count);
 

services/apps/members_enrichment_worker/src/activities/enrichment.ts

@@ -765,7 +765,7 @@ export async function getObsoleteSourcesOfMember(
 }
 
 export async function refreshMemberEnrichmentMaterializedView(mvName: string): Promise<void> {
-  await refreshMaterializedView(svc.postgres.writer.connection(), mvName)
+  await refreshMaterializedView(svc.postgres.writer.connection(), mvName, true)
 }
 
 interface IWorkExperienceChanges {

services/apps/members_enrichment_worker/src/workflows/refreshMemberEnrichmentMaterializedViews.ts

@@ -5,7 +5,12 @@ import { MemberEnrichmentMaterializedView } from '@crowd/types'
 import * as activities from '../activities'
 
 const { refreshMemberEnrichmentMaterializedView } = proxyActivities<typeof activities>({
-  startToCloseTimeout: '10 minutes',
+  startToCloseTimeout: '45 minutes',
+  retry: {
+    initialInterval: '15 seconds',
+    backoffCoefficient: 2,
+    maximumAttempts: 3,
+  },
 })
 
 export async function refreshMemberEnrichmentMaterializedViews(): Promise<void> {