use the internal db pool for pipeline loads

proofcarryingdata · Nov 12, 2024 · 05e4f91 · 05e4f91
1 parent 6c1a770
commit 05e4f91
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/apps/passport-server/src/services/generic-issuance/subservices/PipelineExecutorSubservice.ts b/apps/passport-server/src/services/generic-issuance/subservices/PipelineExecutorSubservice.ts
@@ -101,7 +101,7 @@ export class PipelineExecutorSubservice {
    * schedules a load loop which loads data for each {@link Pipeline} once per minute.
    */
   public async start(startLoadLoop?: boolean): Promise<void> {
-    await sqlTransaction(this.context.dbPool, (client) =>
+    await sqlTransaction(this.context.internalPool, (client) =>
       this.loadAndInstantiatePipelines(client)
     );
 
@@ -357,7 +357,7 @@ export class PipelineExecutorSubservice {
         }
 
         let runInfo = await performPipelineLoad(
-          this.context.dbPool,
+          this.context.internalPool,
           pipelineSlot,
           this.pipelineSubservice,
           this.userSubservice,
@@ -502,7 +502,7 @@ export class PipelineExecutorSubservice {
     // function - that will be done the next time `startPipelineLoadLoop`
     // is called.
     await namedSqlTransaction(
-      this.context.dbPool,
+      this.context.internalPool,
       "startPipelineLoadLoop",
       async (client) => {
         await this.loadAndInstantiatePipelines(client);

diff --git a/apps/passport-server/src/services/semaphoreService.ts b/apps/passport-server/src/services/semaphoreService.ts
@@ -57,7 +57,7 @@ export class SemaphoreService {
   public groupDevconnectOrganizers = (): NamedGroup => this.getNamedGroup("7");
 
   public constructor(config: ApplicationContext) {
-    this.dbPool = config.dbPool;
+    this.dbPool = config.internalPool;
     this.groups = SemaphoreService.createGroups();
   }