From fb0dc214ea6c408a59c8d49b1cebb245b2249183 Mon Sep 17 00:00:00 2001 From: Vijay Gupta Date: Wed, 11 Dec 2024 17:31:57 +0530 Subject: [PATCH] backend:kv-delete-query-fix --- src/EulerHS/KVConnector/Flow.hs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/EulerHS/KVConnector/Flow.hs b/src/EulerHS/KVConnector/Flow.hs index 3c9d1ce8..f1555e8f 100644 --- a/src/EulerHS/KVConnector/Flow.hs +++ b/src/EulerHS/KVConnector/Flow.hs @@ -637,7 +637,7 @@ updateKVAndDBResults meshCfg whereClause eitherDbRows eitherKvRows mbUpdateVals kvDeadRows = snd allKVRows kvLiveAndDeadRows = kvLiveRows ++ kvDeadRows matchedKVLiveRows = findAllMatching whereClause kvLiveRows - if isRecachingEnabled && meshCfg.meshEnabled + if isRecachingEnabled && meshCfg.meshEnabled && isLive then do let uniqueDbRows = getUniqueDBRes meshCfg.redisKeyPrefix allDBRows kvLiveAndDeadRows reCacheDBRowsRes <- reCacheDBRows meshCfg uniqueDbRows @@ -645,9 +645,7 @@ updateKVAndDBResults meshCfg whereClause eitherDbRows eitherKvRows mbUpdateVals Left err -> return $ Left $ RedisError (show err <> "Primary key => " <> show (getLookupKeyByPKey meshCfg.redisKeyPrefix <$> uniqueDbRows) <> " Secondary key => " <> show (getSecondaryLookupKeys meshCfg.redisKeyPrefix <$> uniqueDbRows) <> " in updateKVAndDBResults") Right _ -> do let allRows = matchedKVLiveRows ++ uniqueDbRows - sequence <$> if isLive - then mapM (updateObjectRedis meshCfg updVals setClause True whereClause) allRows - else mapM (deleteObjectRedis meshCfg True whereClause) allRows + sequence <$> mapM (updateObjectRedis meshCfg updVals setClause True whereClause) allRows else do updateOrDelKVRowRes <- if isLive then mapM (updateObjectRedis meshCfg updVals setClause True whereClause) matchedKVLiveRows