diff --git a/src/overhaul_activity/service.py b/src/overhaul_activity/service.py
index 8ecde11..05d7881 100644
--- a/src/overhaul_activity/service.py
+++ b/src/overhaul_activity/service.py
@@ -128,7 +128,7 @@ async def create(*, db_session: DbSession, overhaul_activty_in: OverhaulActivity
         )
 
     # Execute the statement
-    db_session.execute(stmt)
+    await db_session.execute(stmt)
     await db_session.execute(
         sqlUpdate(OverhaulActivity)
         .where(OverhaulActivity.overhaul_scope_id == overhaul_session_id)