Skip to content

Commit be11a5d

Browse files
authored
fix: use LF agent audit fallback for worker member merges (#4200)
Signed-off-by: Yeganathan S <63534555+skwowet@users.noreply.github.com>
1 parent 8ea4d47 commit be11a5d

3 files changed

Lines changed: 3 additions & 15 deletions

File tree

  • services/apps
    • members_enrichment_worker/src/activities
    • merge_suggestions_worker/src/activities
    • script_executor_worker/src/activities

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

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -112,11 +112,7 @@ export async function mergeMembers(
112112
const memberService = new CommonMemberService(qx, svc.temporal, svc.log)
113113

114114
try {
115-
await memberService.merge(primaryMemberId, secondaryMemberId, {
116-
currentUser: {
117-
id: process.env['CROWD_LF_AGENT_USER_ID'],
118-
},
119-
})
115+
await memberService.merge(primaryMemberId, secondaryMemberId)
120116
} catch (error) {
121117
svc.log.error({ err: error }, 'Failed to merge members')
122118
throw error

services/apps/merge_suggestions_worker/src/activities/common.ts

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -108,11 +108,7 @@ export async function mergeMembers(
108108
const memberService = new CommonMemberService(qx, svc.temporal, svc.log)
109109

110110
try {
111-
await memberService.merge(primaryMemberId, secondaryMemberId, {
112-
currentUser: {
113-
id: process.env['CROWD_LF_AGENT_USER_ID'],
114-
},
115-
})
111+
await memberService.merge(primaryMemberId, secondaryMemberId)
116112
} catch (error) {
117113
svc.log.error({ err: error }, 'Failed to merge members')
118114
throw error

services/apps/script_executor_worker/src/activities/common.ts

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,7 @@ export async function mergeMembers(
2020
const memberService = new CommonMemberService(qx, svc.temporal, svc.log)
2121

2222
try {
23-
await memberService.merge(primaryMemberId, secondaryMemberId, {
24-
currentUser: {
25-
id: process.env['CROWD_LF_AGENT_USER_ID'],
26-
},
27-
})
23+
await memberService.merge(primaryMemberId, secondaryMemberId)
2824
} catch (error) {
2925
svc.log.error({ err: error }, 'Failed to merge members')
3026
throw error

0 commit comments

Comments
 (0)