diff --git a/insights/insights/doctype/insights_data_source/sources/base_database.py b/insights/insights/doctype/insights_data_source/sources/base_database.py
index d9cbc88b7..6c1d1ace3 100644
--- a/insights/insights/doctype/insights_data_source/sources/base_database.py
+++ b/insights/insights/doctype/insights_data_source/sources/base_database.py
@@ -5,7 +5,6 @@
 
 import frappe
 from sqlalchemy.sql import text
-from tenacity import retry, retry_if_exception_type, stop_after_attempt, wait_fixed
 
 from insights.insights.doctype.insights_table_import.insights_table_import import (
     InsightsTableImport,
@@ -88,12 +87,6 @@ def test_connection(self):
             res = connection.execute(text("SELECT 1"))
             return res.fetchone()
 
-    @retry(
-        retry=retry_if_exception_type((DatabaseParallelConnectionError,)),
-        stop=stop_after_attempt(5),
-        wait=wait_fixed(1),
-        reraise=True,
-    )
     def connect(self):
         try:
             return self.engine.connect()