fix: update member enrichment last tried timestamp on failure

skwowet · skwowet · commit fdc07828c02a · 2025-10-17T19:30:32.000+05:30
diff --git a/services/apps/members_enrichment_worker/src/activities/enrichment.ts b/services/apps/members_enrichment_worker/src/activities/enrichment.ts
@@ -459,6 +459,8 @@ export async function updateMemberUsingSquashedPayload(
     if (updated) {
       await setMemberEnrichmentUpdatedAt(tx.transaction(), memberId)
       await syncMember(memberId)
+    } else {
+      await setMemberEnrichmentLastTriedAt(tx.transaction(), memberId)
     }
 
     svc.log.debug({ memberId }, 'Member sources processed successfully!')

Original file line number	Diff line number	Diff line change
`@@ -459,6 +459,8 @@ export async function updateMemberUsingSquashedPayload(`
`459`	`459`	`if (updated) {`
`460`	`460`	`await setMemberEnrichmentUpdatedAt(tx.transaction(), memberId)`
`461`	`461`	`await syncMember(memberId)`
	`462`	`+ } else {`
	`463`	`+ await setMemberEnrichmentLastTriedAt(tx.transaction(), memberId)`
`462`	`464`	`}`
`463`	`465`
`464`	`466`	`svc.log.debug({ memberId }, 'Member sources processed successfully!')`