diff --git a/pkg/storage/redis/redis.go b/pkg/storage/redis/redis.go
index 6e38f5c27..7f762bb5a 100644
--- a/pkg/storage/redis/redis.go
+++ b/pkg/storage/redis/redis.go
@@ -116,6 +116,7 @@ func (db *DB) Delete(ctx context.Context, id string) (err error) {
 
 			// mark it as deleted
 			record.DeletedAt = timestamppb.Now()
+			record.Version = formatVersion(version)
 
 			return nil
 		},
diff --git a/pkg/storage/redis/redis_test.go b/pkg/storage/redis/redis_test.go
index 832cc2f7d..f1f1a904b 100644
--- a/pkg/storage/redis/redis_test.go
+++ b/pkg/storage/redis/redis_test.go
@@ -144,11 +144,14 @@ func testDB(t *testing.T) {
 		}
 	})
 	t.Run("delete record", func(t *testing.T) {
+		original, err := db.Get(ctx, id)
+		require.NoError(t, err)
 		assert.NoError(t, db.Delete(ctx, id))
 		record, err := db.Get(ctx, id)
 		require.NoError(t, err)
 		require.NotNil(t, record)
 		assert.NotNil(t, record.DeletedAt)
+		assert.NotEqual(t, original.GetVersion(), record.GetVersion())
 	})
 	t.Run("clear deleted", func(t *testing.T) {
 		db.ClearDeleted(ctx, time.Now().Add(time.Second))