diff --git a/packages/cardano-services/test/Http/HttpServer.test.ts b/packages/cardano-services/test/Http/HttpServer.test.ts
index 1dfee57991e..a8d9b4ae28d 100644
--- a/packages/cardano-services/test/Http/HttpServer.test.ts
+++ b/packages/cardano-services/test/Http/HttpServer.test.ts
@@ -94,6 +94,8 @@ describe('HttpServer', () => {
     provider = new DbSyncUtxoProvider({ cache, cardanoNode, dbPools, logger });
   });
 
+  afterAll(() => Promise.all([dbPools.healthCheck.end(), dbPools.main.end()]));
+
   describe('initialize', () => {
     afterEach(() => httpServer.shutdown());
     it('initializes the express application', async () => {
diff --git a/packages/cardano-services/test/PgBoss/stakePoolBatchDelistHandler.test.ts b/packages/cardano-services/test/PgBoss/stakePoolBatchDelistHandler.test.ts
index d1ae2556f28..00bba3f155c 100644
--- a/packages/cardano-services/test/PgBoss/stakePoolBatchDelistHandler.test.ts
+++ b/packages/cardano-services/test/PgBoss/stakePoolBatchDelistHandler.test.ts
@@ -1,4 +1,5 @@
 import { DataSource } from 'typeorm';
+import { Pool } from 'pg';
 import { PoolDelistedEntity } from '@cardano-sdk/projection-typeorm';
 import { WorkerHandlerFactoryOptions } from '../../src/PgBoss';
 import { createSmashStakePoolDelistedService } from '../../src/StakePool/HttpStakePoolMetadata/SmashStakePoolDelistedService';
@@ -10,11 +11,16 @@ jest.mock('../../src/StakePool/HttpStakePoolMetadata/SmashStakePoolDelistedServi
 
 describe('stakePoolBatchDelistHandler', () => {
   let dataSource: DataSource;
+  let db: Pool;
 
   beforeAll(async () => {
     const testData = await initHandlerTest();
-    dataSource = testData.dataSource;
+
+    ({ dataSource, db } = testData);
   });
+
+  afterAll(() => Promise.all([db.end(), dataSource.destroy()]));
+
   it('contain latest delisted pools only', async () => {
     // Padded by spaces because pool id length is fixed to 56 chars
     const expected = ['pool1', 'pool2', 'pool3'].map((p) => p.padEnd(56, ' '));
diff --git a/packages/cardano-services/test/PgBoss/stakePoolMetadataHandler.test.ts b/packages/cardano-services/test/PgBoss/stakePoolMetadataHandler.test.ts
index 128cdff862e..ac491ef52ae 100644
--- a/packages/cardano-services/test/PgBoss/stakePoolMetadataHandler.test.ts
+++ b/packages/cardano-services/test/PgBoss/stakePoolMetadataHandler.test.ts
@@ -2,6 +2,7 @@ import { Cardano, NotImplementedError, ProviderError, ProviderFailure } from '@c
 import { DataMocks } from '../data-mocks';
 import { DataSource } from 'typeorm';
 import { Hash32ByteBase16 } from '@cardano-sdk/crypto';
+import { Pool } from 'pg';
 import { PoolMetadataEntity, PoolRegistrationEntity } from '@cardano-sdk/projection-typeorm';
 import { StakePoolMetadataFetchMode } from '../../src/Program/options';
 import {
@@ -17,11 +18,12 @@ describe('stakePoolMetadataHandler', () => {
   const vrf = 'test_vfr';
 
   let dataSource: DataSource;
+  let db: Pool;
 
   beforeAll(async () => {
     const testData = await initHandlerTest();
     const { block, stakePool } = testData;
-    ({ dataSource } = testData);
+    ({ dataSource, db } = testData);
 
     const registrationRepos = dataSource.getRepository(PoolRegistrationEntity);
     const registration1 = {
@@ -47,6 +49,8 @@ describe('stakePoolMetadataHandler', () => {
     await registrationRepos.insert(registration2);
   });
 
+  afterAll(() => Promise.all([db.end(), dataSource.destroy()]));
+
   describe('isUpdateOutdated', () => {
     it('returns true if there is a newer pool update', async () => {
       expect(await isUpdateOutdated(dataSource, poolId, '23')).toBe(true);
@@ -108,6 +112,7 @@ describe('stakePoolMetadataHandler', () => {
       expect(await metadataRepos.find({ where: { poolUpdate } })).toEqual([]);
     });
   });
+
   describe('attachExtendedMetadata', () => {
     const metadata = {
       description: 'description',
diff --git a/packages/cardano-services/test/PgBoss/stakePoolMetricsHandler.test.ts b/packages/cardano-services/test/PgBoss/stakePoolMetricsHandler.test.ts
index 72f145e2796..cb6f38a7101 100644
--- a/packages/cardano-services/test/PgBoss/stakePoolMetricsHandler.test.ts
+++ b/packages/cardano-services/test/PgBoss/stakePoolMetricsHandler.test.ts
@@ -2,6 +2,7 @@ import { Cardano, StakePoolProvider } from '@cardano-sdk/core';
 import { CurrentPoolMetricsEntity, StakePoolEntity } from '@cardano-sdk/projection-typeorm';
 import { DataSource } from 'typeorm';
 import { Percent } from '@cardano-sdk/util';
+import { Pool } from 'pg';
 import { Repository } from 'typeorm/repository/Repository';
 import { getPoolIdsToUpdate, savePoolMetrics } from '../../src/PgBoss/stakePoolMetricsHandler';
 import { initHandlerTest, poolId } from './util';
@@ -9,6 +10,7 @@ import { logger } from '@cardano-sdk/util-dev';
 
 describe('stakePoolMetricsHandler', () => {
   let dataSource: DataSource;
+  let db: Pool;
   let metricsRepos: Repository<CurrentPoolMetricsEntity>;
   const metrics: Cardano.StakePoolMetrics = {
     blocksCreated: 23,
@@ -23,11 +25,13 @@ describe('stakePoolMetricsHandler', () => {
 
   beforeAll(async () => {
     const testData = await initHandlerTest();
-    ({ dataSource } = testData);
+    ({ dataSource, db } = testData);
 
     metricsRepos = dataSource.getRepository(CurrentPoolMetricsEntity);
   });
 
+  afterAll(() => Promise.all([db.end(), dataSource.destroy()]));
+
   describe('getPoolIdsToUpdate', () => {
     const partialOptions = {
       dataSource,
diff --git a/packages/cardano-services/test/PgBoss/util.ts b/packages/cardano-services/test/PgBoss/util.ts
index 4618c0ffcb8..bda505cb42a 100644
--- a/packages/cardano-services/test/PgBoss/util.ts
+++ b/packages/cardano-services/test/PgBoss/util.ts
@@ -55,5 +55,5 @@ export const initHandlerTest = async () => {
   await blockRepos.insert(block);
   await poolRepos.insert(stakePool);
 
-  return { block, dataSource, stakePool };
+  return { block, dataSource, db, stakePool };
 };