diff --git a/redis-om-spring/src/main/java/com/redis/om/spring/RedisEnhancedKeyValueAdapter.java b/redis-om-spring/src/main/java/com/redis/om/spring/RedisEnhancedKeyValueAdapter.java
index 31a5b011..41753107 100644
--- a/redis-om-spring/src/main/java/com/redis/om/spring/RedisEnhancedKeyValueAdapter.java
+++ b/redis-om-spring/src/main/java/com/redis/om/spring/RedisEnhancedKeyValueAdapter.java
@@ -153,10 +153,9 @@ public Object put(Object id, Object item, String keyspace) {
       rdo.setId(converter.getConversionService().convert(id, String.class));
     }
 
-    byte[] objectKey = createKey(sanitizeKeyspace(rdo.getKeyspace()), rdo.getId());
-    redisOperations.execute((RedisCallback<Boolean>) connection -> connection.keyCommands().del(objectKey) == 0);
-
     redisOperations.executePipelined((RedisCallback<Object>) connection -> {
+      byte[] objectKey = createKey(sanitizeKeyspace(rdo.getKeyspace()), rdo.getId());
+      connection.keyCommands().del(objectKey);
       Map<byte[], byte[]> rawMap = rdo.getBucket().rawMap();
       connection.hashCommands().hMSet(objectKey, rawMap);