diff --git a/backend/src/database/repositories/memberRepository.ts b/backend/src/database/repositories/memberRepository.ts index e8faab05ef..7ad7a90909 100644 --- a/backend/src/database/repositories/memberRepository.ts +++ b/backend/src/database/repositories/memberRepository.ts @@ -1192,7 +1192,11 @@ class MemberRepository { include: Record = {}, ) { let memberResponse = null - memberResponse = await queryMembersAdvanced(optionsQx(options), options.redis, { + + const qx = optionsQx(options) + const bgQx = optionsQx({ ...options, transaction: null }) + + memberResponse = await queryMembersAdvanced(qx, bgQx, options.redis, { filter: { id: { eq: id } }, limit: 1, offset: 0, @@ -1211,7 +1215,7 @@ class MemberRepository { if (memberResponse.count === 0) { // try it again without segment information (no aggregates) // for members without activities - memberResponse = await queryMembersAdvanced(optionsQx(options), options.redis, { + memberResponse = await queryMembersAdvanced(qx, bgQx, options.redis, { filter: { id: { eq: id } }, limit: 1, offset: 0, diff --git a/backend/src/services/memberService.ts b/backend/src/services/memberService.ts index 1321f47e13..9f5fad45a8 100644 --- a/backend/src/services/memberService.ts +++ b/backend/src/services/memberService.ts @@ -1353,7 +1353,10 @@ export default class MemberService extends LoggerBase { } async findAllAutocomplete(data) { - return queryMembersAdvanced(optionsQx(this.options), this.options.redis, { + const qx = optionsQx(this.options) + const bgQx = optionsQx({ ...this.options, transaction: null }) + + return queryMembersAdvanced(qx, bgQx, this.options.redis, { filter: data.filter, offset: data.offset, orderBy: data.orderBy, @@ -1398,7 +1401,10 @@ export default class MemberService extends LoggerBase { throw new Error400(this.options.language, 'member.segmentsRequired') } - return queryMembersAdvanced(optionsQx(this.options), this.options.redis, { + const qx = optionsQx(this.options) + const bgQx = optionsQx({ ...this.options, transaction: null }) + + return queryMembersAdvanced(qx, bgQx, this.options.redis, { ...data, segmentId, attributesSettings: memberAttributeSettings, diff --git a/services/libs/data-access-layer/src/members/base.ts b/services/libs/data-access-layer/src/members/base.ts index f51c1bbfd1..9e0bbd3072 100644 --- a/services/libs/data-access-layer/src/members/base.ts +++ b/services/libs/data-access-layer/src/members/base.ts @@ -137,6 +137,7 @@ const QUERY_FILTER_COLUMN_MAP: Map