diff --git a/diracx-db/src/diracx/db/sql/job/db.py b/diracx-db/src/diracx/db/sql/job/db.py
index 7817bb39..c082c6d0 100644
--- a/diracx-db/src/diracx/db/sql/job/db.py
+++ b/diracx-db/src/diracx/db/sql/job/db.py
@@ -295,7 +295,7 @@ async def set_job_command(self, job_id: int, command: str, arguments: str = ""):
 
     async def set_job_command_bulk(self, commands):
         """Store a command to be passed to the job together with the next heart beat."""
-        self.conn.execute(
+        await self.conn.execute(
             insert(JobCommands),
             [
                 {