fix: make jobloggingdb compatible with mysql

DIRACGrid · Sep 12, 2023 · d677dbf · d677dbf
1 parent e536567
commit d677dbf
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/diracx/db/jobs/db.py b/src/diracx/db/jobs/db.py
@@ -288,11 +288,11 @@ async def insert_record(
         UTC time is used.
         """
 
-        seqnum_stmt = (
-            select(func.coalesce(func.max(LoggingInfo.SeqNum) + 1, 1))
-            .where(LoggingInfo.JobID == job_id)
-            .scalar_subquery()
+        # First, fetch the maximum SeqNum for the given job_id
+        seqnum_stmt = select(func.coalesce(func.max(LoggingInfo.SeqNum) + 1, 1)).where(
+            LoggingInfo.JobID == job_id
         )
+        seqnum = await self.conn.scalar(seqnum_stmt)
 
         epoc = (
             time.mktime(date.timetuple())
@@ -302,7 +302,7 @@ async def insert_record(
 
         stmt = insert(LoggingInfo).values(
             JobID=int(job_id),
-            SeqNum=seqnum_stmt,
+            SeqNum=seqnum,
             Status=status,
             MinorStatus=minor_status,
             ApplicationStatus=application_status[:255],