diff --git a/client/go/client_test.go b/client/go/client_test.go index 95f50a2..c745182 100644 --- a/client/go/client_test.go +++ b/client/go/client_test.go @@ -138,13 +138,13 @@ func TestQuery(t *testing.T) { c.Query(`chevy`, data, meta) - if waitTimeout(&wg, 5*time.Second) { + if waitTimeout(&wg, 10*time.Second) { t.Fatal("Timed out waiting for wait group") } } func TestFetch(t *testing.T) { - data, meta, err := Fetch(HOST, PORT, 100, -1, `chevy`, 20, 5*time.Second) + data, meta, err := Fetch(HOST, PORT, 100, -1, `chevy`, 20, 10*time.Second) assert.Nil(t, err) assert.Equal(t, `{"current":20,"total":15000,"numberOfWritten":19,"leftOff":80,"truncatedTimestamp":0}`, string(meta))