Remove 1 when getting db connection (#1421)

Author: garrrikkotua

services/apps/integration_data_worker/src/bin/process-data-for-tenant.ts

@@ -21,7 +21,7 @@ setImmediate(async () => {
   const emitter = new IntegrationDataWorkerEmitter(sqsClient, log)
   await emitter.init()
 
-  const dbConnection = await getDbConnection(DB_CONFIG(), 1)
+  const dbConnection = await getDbConnection(DB_CONFIG())
   const store = new DbStore(log, dbConnection)
   const repo = new IntegrationDataRepository(store, log)
 

services/apps/integration_data_worker/src/bin/process-data.ts

@@ -21,7 +21,7 @@ setImmediate(async () => {
   const emitter = new IntegrationDataWorkerEmitter(sqsClient, log)
   await emitter.init()
 
-  const dbConnection = await getDbConnection(DB_CONFIG(), 1)
+  const dbConnection = await getDbConnection(DB_CONFIG())
   const store = new DbStore(log, dbConnection)
   const repo = new IntegrationDataRepository(store, log)
 

services/apps/integration_run_worker/src/bin/continue-run.ts

@@ -16,14 +16,16 @@ setImmediate(async () => {
   const emitter = new IntegrationRunWorkerEmitter(sqsClient, log)
   await emitter.init()
 
-  const dbConnection = await getDbConnection(DB_CONFIG(), 1)
+  const dbConnection = await getDbConnection(DB_CONFIG())
   const store = new DbStore(log, dbConnection)
 
   const repo = new IntegrationRunRepository(store, log)
 
   const run = await repo.findIntegrationRunById(runId)
 
   if (run) {
+    log.info({ run }, 'Found run!')
+
     if (run.state != IntegrationRunState.PENDING) {
       log.warn(`Integration run is not pending, setting to pending!`)
 

services/apps/integration_run_worker/src/bin/onboard-integration.ts

@@ -16,7 +16,7 @@ setImmediate(async () => {
   const emitter = new IntegrationRunWorkerEmitter(sqsClient, log)
   await emitter.init()
 
-  const dbConnection = await getDbConnection(DB_CONFIG(), 1)
+  const dbConnection = await getDbConnection(DB_CONFIG())
   const store = new DbStore(log, dbConnection)
 
   const repo = new IntegrationRunRepository(store, log)

services/apps/integration_run_worker/src/bin/process-repo.ts

@@ -68,7 +68,7 @@ setImmediate(async () => {
   const emitter = new IntegrationRunWorkerEmitter(sqsClient, log)
   await emitter.init()
 
-  const dbConnection = await getDbConnection(DB_CONFIG(), 1)
+  const dbConnection = await getDbConnection(DB_CONFIG())
   const store = new DbStore(log, dbConnection)
 
   const repo = new IntegrationRunRepository(store, log)

services/apps/integration_run_worker/src/bin/trigger-all-onboardings.ts

@@ -13,7 +13,7 @@ setImmediate(async () => {
   const emitter = new IntegrationRunWorkerEmitter(sqsClient, log)
   await emitter.init()
 
-  const dbConnection = await getDbConnection(DB_CONFIG(), 1)
+  const dbConnection = await getDbConnection(DB_CONFIG())
   const store = new DbStore(log, dbConnection)
 
   const repo = new IntegrationRunRepository(store, log)

services/apps/integration_stream_worker/src/bin/process-stream.ts

@@ -21,7 +21,7 @@ setImmediate(async () => {
   const emitter = new IntegrationStreamWorkerEmitter(sqsClient, log)
   await emitter.init()
 
-  const dbConnection = await getDbConnection(DB_CONFIG(), 1)
+  const dbConnection = await getDbConnection(DB_CONFIG())
   const store = new DbStore(log, dbConnection)
   const repo = new IntegrationStreamRepository(store, log)