Skip to content

Commit a4ac8df

Browse files
removed leftover prints
1 parent ea795e3 commit a4ac8df

File tree

3 files changed

+0
-6
lines changed

3 files changed

+0
-6
lines changed

internal/routing/policy.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,5 @@ func (p *CommandPolicy) CanBeUsedInPipeline() bool {
140140

141141
func (p *CommandPolicy) IsReadOnly() bool {
142142
_, readOnly := p.Tips[ReadOnlyCMD]
143-
fmt.Println(readOnly)
144143
return readOnly
145144
}

osscluster_router.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -50,10 +50,7 @@ func (c *ClusterClient) executeDefault(ctx context.Context, cmd Cmder, policy *r
5050
return node.Client.Process(ctx, cmd)
5151
}
5252
if policy != nil {
53-
54-
fmt.Println(policy.Tips)
5553
if c.readOnlyEnabled() && policy.IsReadOnly() {
56-
fmt.Println("will execute on arbitrary node")
5754
return c.executeOnArbitraryNode(ctx, cmd)
5855
}
5956
}

osscluster_test.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@ import (
66
"errors"
77
"fmt"
88
"net"
9-
"reflect"
109
"slices"
1110
"strconv"
1211
"strings"
@@ -1567,7 +1566,6 @@ var _ = Describe("ClusterClient timeout", func() {
15671566
return nil
15681567
})
15691568
Expect(err).To(HaveOccurred())
1570-
fmt.Println("qko greshki male", reflect.TypeOf(err).String(), reflect.TypeOf(err).Kind().String())
15711569
Expect(err.(net.Error).Timeout()).To(BeTrue())
15721570
})
15731571

0 commit comments

Comments
 (0)