Skip to content

Commit 9c1eb1f

Browse files
committed
fix: insert statement
1 parent 3081d48 commit 9c1eb1f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/DIRAC/AccountingSystem/DB/AccountingDB.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -510,7 +510,7 @@ def __addKeyValue(self, typeName, keyName, keyValue):
510510
return retVal
511511
connection = retVal["Value"]
512512
self.log.info(f"Value {keyValue} for key {keyName} didn't exist, inserting")
513-
retVal = self.insertFields(keyTable, ["id", "value"], [0, keyValue], conn=connection)
513+
retVal = self.insertFields(keyTable, ["value"], [keyValue], conn=connection)
514514
if not retVal["OK"] and retVal["Message"].find("Duplicate key") == -1:
515515
return retVal
516516
result = self.__getIdForKeyValue(typeName, keyName, keyValue, conn=connection)
@@ -553,8 +553,8 @@ def calculateBuckets(self, typeName, startTime, endTime, nowEpoch=False):
553553
return buckets
554554

555555
def __insertInQueueTable(self, typeName, startTime, endTime, valuesList):
556-
sqlFields = ["id", "taken", "takenSince"] + self.dbCatalog[typeName]["typeFields"]
557-
sqlValues = ["0", "0", "UTC_TIMESTAMP()"] + valuesList + [startTime, endTime]
556+
sqlFields = ["taken", "takenSince"] + self.dbCatalog[typeName]["typeFields"]
557+
sqlValues = ["0", "UTC_TIMESTAMP()"] + valuesList + [startTime, endTime]
558558
if len(sqlFields) != len(sqlValues):
559559
numRcv = len(valuesList) + 2
560560
numExp = len(self.dbCatalog[typeName]["typeFields"])

0 commit comments

Comments
 (0)