diff --git a/src/aeros_equipment/service.py b/src/aeros_equipment/service.py
index 5e1b6b2..31c8322 100644
--- a/src/aeros_equipment/service.py
+++ b/src/aeros_equipment/service.py
@@ -326,13 +326,13 @@ async def update_oh_interval_offset(*, aeros_db_session, overhaul_offset, overha
         AND p."ProjectName" = :project_name
     """)
 
-    aeros_db_session.execute(query, {
+    await aeros_db_session.execute(query, {
         "new_oh_interval": overhaul_interval,
         "new_oh_offset": overhaul_offset,
         "project_name": project_name
     })
     
-    aeros_db_session.commit()
+    await aeros_db_session.commit()
 
 
 async def update_equipment_for_simulation(*, db_session: DbSession,aeros_db_session:CollectorDbSession ,project_name: str,overhaul_duration, overhaul_interval, offset ,schematic_name: str, custom_input: Optional[dict] = None):