fix

Author: Evan Roman

src/sql.test.ts

@@ -31,10 +31,6 @@ describe('sql', () => {
         const id = uuid();
         const testData = getRandomTestData();
 
-        if (!poolConnection) {
-            throw new Error('SQL connection pool is not initialized');
-        }
-
         // trigger by insert
         await poolConnection!.request().query(`INSERT INTO ${Sql.sqlTriggerTable} VALUES ('${id}', '${testData}');`);
         await waitForOutput(`sqlTrigger processed 1 changes`);

src/utils/cosmosdb/setupCosmosDB.ts

@@ -8,10 +8,8 @@
 import { CosmosClient, PartitionKeyKind } from '@azure/cosmos';
 import { cosmosDBConnectionString } from '../connectionStrings';
 import { CosmosDB } from '../../constants';
-import { delay } from '../delay';
 
 export async function setupCosmosDB() {
-  try {
     const partitionKeyPath = `/${CosmosDB.partitionKey}`;
     if (!cosmosDBConnectionString) {
       throw new Error('CosmosDB connection string is not set');
@@ -26,9 +24,4 @@ export async function setupCosmosDB() {
       id: CosmosDB.triggerAndOutputContainerName,
       partitionKey: { paths: [partitionKeyPath], kind: PartitionKeyKind.Hash }
     });
-} catch (error) {
-    console.error('Error setting up CosmosDB:', error);
-    throw error;
-  }
-  await delay(30000);
 }

src/utils/sql/setupSql.ts

@@ -9,19 +9,14 @@ import { Sql } from '../../constants';
 export async function runSqlSetupQueries() {
     // STEP 1: Create DB if not exists
     let pool = await createPoolConnnection(sqlConnectionString);
-    try {
-        await pool.request().query(`
-            IF NOT EXISTS (SELECT name FROM sys.databases WHERE name = '${Sql.dbName}')
-            BEGIN
-                CREATE DATABASE [${Sql.dbName}];
-            END
-        `);
-    } finally {
-        await pool.close();
-    }
+    await pool.request().query(`
+        IF NOT EXISTS (SELECT name FROM sys.databases WHERE name = '${Sql.dbName}')
+        BEGIN
+            CREATE DATABASE [${Sql.dbName}];
+        END
+    `);
 
     // STEP 2: Retry ALTER DATABASE (change_tracking)
-    pool = await createPoolConnnection(sqlConnectionString);
     try {
         await retry(async (currentAttempt) => {
             if (currentAttempt > 1) {
@@ -44,9 +39,6 @@ export async function runSqlSetupQueries() {
             retries: 5,
             minTimeout: 5000
         });
-    } catch (err) {
-        console.error("ALTER DATABASE failed:", err);
-        throw err;
     } finally {
         await pool.close();
     }