Merge pull request #357 from chrisburr/missing-await

Add missing await in JobDB
DIRACGrid · Dec 20, 2024 · 0bc35d3 · 0bc35d3
2 parents 320c554 + b3748c3
commit 0bc35d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/diracx-db/src/diracx/db/sql/job/db.py b/diracx-db/src/diracx/db/sql/job/db.py
@@ -286,7 +286,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),
             [
                 {