fix: insert statement

fstagni · Feb 26, 2024 · 434c78e · 434c78e
1 parent 77978a6
commit 434c78e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/DIRAC/AccountingSystem/DB/AccountingDB.py b/src/DIRAC/AccountingSystem/DB/AccountingDB.py
@@ -498,7 +498,7 @@ def __addKeyValue(self, typeName, keyName, keyValue):
             return retVal
         connection = retVal["Value"]
         self.log.info(f"Value {keyValue} for key {keyName} didn't exist, inserting")
-        retVal = self.insertFields(keyTable, ["id", "value"], [0, keyValue], conn=connection)
+        retVal = self.insertFields(keyTable, ["value"], [keyValue], conn=connection)
         if not retVal["OK"] and retVal["Message"].find("Duplicate key") == -1:
             return retVal
         result = self.__getIdForKeyValue(typeName, keyName, keyValue, conn=connection)
@@ -541,8 +541,8 @@ def calculateBuckets(self, typeName, startTime, endTime, nowEpoch=False):
         return buckets
 
     def __insertInQueueTable(self, typeName, startTime, endTime, valuesList):
-        sqlFields = ["id", "taken", "takenSince"] + self.dbCatalog[typeName]["typeFields"]
-        sqlValues = ["0", "0", "UTC_TIMESTAMP()"] + valuesList + [startTime, endTime]
+        sqlFields = ["taken", "takenSince"] + self.dbCatalog[typeName]["typeFields"]
+        sqlValues = ["0", "UTC_TIMESTAMP()"] + valuesList + [startTime, endTime]
         if len(sqlFields) != len(sqlValues):
             numRcv = len(valuesList) + 2
             numExp = len(self.dbCatalog[typeName]["typeFields"])