From b3748c3bc3216d88724cd2544f0d822b98aba059 Mon Sep 17 00:00:00 2001 From: Chris Burr Date: Fri, 20 Dec 2024 16:01:10 +0100 Subject: [PATCH] fix: Add missing await in JobDB --- diracx-db/src/diracx/db/sql/job/db.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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), [ {