Update objects with transactions

nytimes · Nov 17, 2023 · 2d7da4d · 2d7da4d
1 parent d9bac62
commit 2d7da4d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/test_test.go b/test_test.go
@@ -63,7 +63,9 @@ func (testHook) ProcessPipelineHook(next redis.ProcessPipelineHook) redis.Proces
 		}
 
 		for _, cmd := range cmds {
-			keys[cmd.Args()[1].(string)] = true
+			if len(cmd.Args()) >= 2 {
+				keys[cmd.Args()[1].(string)] = true
+			}
 		}
 
 		return nil

diff --git a/update.go b/update.go
@@ -95,7 +95,7 @@ func updateInternal(id string, ptr interface{}, opts *UpdateOptions) error {
 	pip := opts.Pipeline
 
 	if opts.Pipeline == nil {
-		pip = C.Pipeline()
+		pip = C.TxPipeline()
 	}
 
 	for i := 0; i < typ.NumField(); i++ {