diff --git a/services/apps/integration_data_worker/src/bin/process-data-for-tenant.ts b/services/apps/integration_data_worker/src/bin/process-data-for-tenant.ts
index e5da4e7d13..4d8807159e 100644
--- a/services/apps/integration_data_worker/src/bin/process-data-for-tenant.ts
+++ b/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)
 
diff --git a/services/apps/integration_data_worker/src/bin/process-data.ts b/services/apps/integration_data_worker/src/bin/process-data.ts
index a28651fce0..ae29f86d5e 100644
--- a/services/apps/integration_data_worker/src/bin/process-data.ts
+++ b/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)
 
diff --git a/services/apps/integration_run_worker/src/bin/continue-run.ts b/services/apps/integration_run_worker/src/bin/continue-run.ts
index 71d5a82946..c9dd72326f 100644
--- a/services/apps/integration_run_worker/src/bin/continue-run.ts
+++ b/services/apps/integration_run_worker/src/bin/continue-run.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)
@@ -24,6 +24,8 @@ setImmediate(async () => {
   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!`)
 
diff --git a/services/apps/integration_run_worker/src/bin/onboard-integration.ts b/services/apps/integration_run_worker/src/bin/onboard-integration.ts
index 9dc8a7b986..33d068f9ae 100644
--- a/services/apps/integration_run_worker/src/bin/onboard-integration.ts
+++ b/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)
diff --git a/services/apps/integration_run_worker/src/bin/process-repo.ts b/services/apps/integration_run_worker/src/bin/process-repo.ts
index 3b474503d1..66f2581dd2 100644
--- a/services/apps/integration_run_worker/src/bin/process-repo.ts
+++ b/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)
diff --git a/services/apps/integration_run_worker/src/bin/trigger-all-onboardings.ts b/services/apps/integration_run_worker/src/bin/trigger-all-onboardings.ts
index b83f30c3bb..ab83cd4e6f 100644
--- a/services/apps/integration_run_worker/src/bin/trigger-all-onboardings.ts
+++ b/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)
diff --git a/services/apps/integration_stream_worker/src/bin/process-stream.ts b/services/apps/integration_stream_worker/src/bin/process-stream.ts
index b9fb064482..cc809c52df 100644
--- a/services/apps/integration_stream_worker/src/bin/process-stream.ts
+++ b/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)