Skip to content

Commit f209629

Browse files
committed
Merge remote-tracking branch 'refs/remotes/origin/preferred-node-id' into preferred-node-id
2 parents 6525184 + c27288e commit f209629

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

internal/query/client.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ type (
3939
closer.Closer
4040

4141
Stats() pool.Stats
42-
With(ctx context.Context, f func(context.Context, *Session) error, opts ...retry.Option) error
42+
With(ctx context.Context, f func(ctx context.Context, s *Session) error, opts ...retry.Option) error
4343
}
4444
Client struct {
4545
config *config.Config

internal/query/client_test.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1590,9 +1590,7 @@ func testPool(
15901590
) *pool.Pool[*Session, Session] {
15911591
return pool.New[*Session, Session](ctx,
15921592
pool.WithLimit[*Session, Session](1),
1593-
pool.WithCreateItemFunc(func(ctx context.Context) (*Session, error) {
1594-
return createSession(ctx)
1595-
}),
1593+
pool.WithCreateItemFunc(createSession),
15961594
pool.WithSyncCloseItem[*Session, Session](),
15971595
)
15981596
}

0 commit comments

Comments
 (0)