review fixes

smnvdev · smnvdev · commit d8bfadd8fe0f · 2025-06-30T01:17:14.000+07:00
diff --git a/ring.go b/ring.go
@@ -814,7 +814,8 @@ func (c *Ring) generalProcessPipeline(
 
 			hook := shard.Client.processPipelineHook
 			if tx {
-				cmds, hook = wrapMultiExec(ctx, cmds), shard.Client.processTxPipelineHook
+				cmds = wrapMultiExec(ctx, cmds)
+				hook = shard.Client.processTxPipelineHook
 			}
 
 			if err = hook(ctx, cmds); err != nil {

Original file line number	Diff line number	Diff line change
`@@ -814,7 +814,8 @@ func (c *Ring) generalProcessPipeline(`
`814`	`814`
`815`	`815`	`hook := shard.Client.processPipelineHook`
`816`	`816`	`if tx {`
`817`		`- cmds, hook = wrapMultiExec(ctx, cmds), shard.Client.processTxPipelineHook`
	`817`	`+ cmds = wrapMultiExec(ctx, cmds)`
	`818`	`+ hook = shard.Client.processTxPipelineHook`
`818`	`819`	`}`
`819`	`820`
`820`	`821`	`if err = hook(ctx, cmds); err != nil {`