Skip to content

Commit bdcd676

Browse files
committed
fix tests.
1 parent 46fd037 commit bdcd676

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sender_pool_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ func TestFlushOnClose(t *testing.T) {
104104
}
105105

106106
func TestPooledSenderDoubleClose(t *testing.T) {
107-
p, err := qdb.PoolFromConf("http::addr=localhost:1234")
107+
p, err := qdb.PoolFromConf("http::addr=localhost:1234;protocol_version=1;")
108108
require.NoError(t, err)
109109

110110
ctx := context.Background()
@@ -122,7 +122,7 @@ func TestPooledSenderDoubleClose(t *testing.T) {
122122

123123
func TestMaxPoolSize(t *testing.T) {
124124
// Create a pool with 2 max senders
125-
p, err := qdb.PoolFromConf("http::addr=localhost:1234", qdb.WithMaxSenders(3))
125+
p, err := qdb.PoolFromConf("http::addr=localhost:1234;protocol_version=1;", qdb.WithMaxSenders(3))
126126
require.NoError(t, err)
127127

128128
ctx := context.Background()

0 commit comments

Comments
 (0)