diff --git a/collectoss/tasks/data_analysis/insight_worker/tasks.py b/collectoss/tasks/data_analysis/insight_worker/tasks.py
index 4bbcc3ed5..123407c58 100644
--- a/collectoss/tasks/data_analysis/insight_worker/tasks.py
+++ b/collectoss/tasks/data_analysis/insight_worker/tasks.py
@@ -106,7 +106,7 @@ def insight_model(repo_git: str,logger,engine) -> None:
                 AND ri_date < :min_date
     """)
 
-    with engine.connect() as conn:
+    with engine.begin() as conn:
         result = conn.execute(delete_record_SQL, parameters=dict(repo_id=repo_id, min_date=min_date))
 
     logger.info("Deleting out of date data points ...\n")