@@ -510,7 +510,7 @@ def __addKeyValue(self, typeName, keyName, keyValue):
510
510
return retVal
511
511
connection = retVal ["Value" ]
512
512
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 )
514
514
if not retVal ["OK" ] and retVal ["Message" ].find ("Duplicate key" ) == - 1 :
515
515
return retVal
516
516
result = self .__getIdForKeyValue (typeName , keyName , keyValue , conn = connection )
@@ -553,8 +553,8 @@ def calculateBuckets(self, typeName, startTime, endTime, nowEpoch=False):
553
553
return buckets
554
554
555
555
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 ]
558
558
if len (sqlFields ) != len (sqlValues ):
559
559
numRcv = len (valuesList ) + 2
560
560
numExp = len (self .dbCatalog [typeName ]["typeFields" ])
0 commit comments