fix: adding a separate context for background requests (CM-798)

backend/src/database/repositories/memberRepository.ts

@@ -1192,7 +1192,11 @@ class MemberRepository {
     include: Record<string, boolean> = {},
   ) {
     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,

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,

services/libs/data-access-layer/src/members/base.ts

@@ -137,6 +137,7 @@ const QUERY_FILTER_COLUMN_MAP: Map<string, { name: string; queryable?: boolean }
 
 export async function queryMembersAdvanced(
   qx: QueryExecutor,
+  bgQx: QueryExecutor,
   redis: RedisClient,
   {
     filter = {},
@@ -186,7 +187,7 @@ export async function queryMembersAdvanced(
   const cachedCount = countOnly ? await cache.getCount(cacheKey) : null
 
   if (cachedResult) {
-    refreshCacheInBackground(qx, redis, cacheKey, {
+    refreshCacheInBackground(bgQx, redis, cacheKey, {
       filter,
       search,
       limit,
@@ -204,7 +205,7 @@ export async function queryMembersAdvanced(
   }
 
   if (countOnly && cachedCount !== null) {
-    refreshCountCacheInBackground(qx, redis, cacheKey, {
+    refreshCountCacheInBackground(bgQx, redis, cacheKey, {
       filter,
       search,
       segmentId,