forcing new database instance when refreshing mvs

Author: epipav

backend/src/bin/jobs/refreshMaterializedViewsForCube.ts

@@ -1,6 +1,6 @@
 import { Logger, logExecutionTimeV2 } from '@crowd/logging'
 import { CrowdJob } from '../../types/jobTypes'
-import { databaseInitNoCache } from '../../database/databaseConnection'
+import { databaseInit } from '../../database/databaseConnection'
 
 let processingRefreshCubeMVs = false
 
@@ -19,7 +19,8 @@ const job: CrowdJob = {
 
     try {
       // initialize database with 15 minutes query timeout
-      const database = await databaseInitNoCache(1000 * 60 * 15)
+      const forceNewDbInstance = true
+      const database = await databaseInit(1000 * 60 * 15, forceNewDbInstance)
 
       const materializedViews = [
         'mv_members_cube',

backend/src/database/databaseConnection.ts

@@ -5,14 +5,17 @@ let cached
 /**
  * Initializes the connection to the Database
  */
-export async function databaseInit(queryTimeoutMilliseconds: number = 30000) {
+export async function databaseInit(
+  queryTimeoutMilliseconds: number = 30000,
+  forceNewInstance: boolean = false,
+) {
+  if (forceNewInstance) {
+    return models(queryTimeoutMilliseconds)
+  }
+
   if (!cached) {
     cached = models(queryTimeoutMilliseconds)
   }
 
   return cached
 }
-
-export async function databaseInitNoCache(queryTimeoutMilliseconds: number = 30000) {
-  return models(queryTimeoutMilliseconds)
-}