Skip to content

Commit

Permalink
Longer wait
Browse files Browse the repository at this point in the history
  • Loading branch information
@gtopper
gtopper committed Jan 16, 2024
1 parent e2bbed4 commit ee86c8c
Show file tree
Hide file tree
Showing 3 changed files with 26 additions and 26 deletions.
34 changes: 17 additions & 17 deletions test/kv_integration_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -342,7 +342,7 @@ func (kvSuite *KvTestSuite) TestAll() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

time.Sleep(3 * time.Second) // Let DB sync
Expand Down Expand Up @@ -402,7 +402,7 @@ func (kvSuite *KvTestSuite) TestRangeScan() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

//check schema
Expand Down Expand Up @@ -506,7 +506,7 @@ func (kvSuite *KvTestSuite) TestNullValuesWrite() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

input := v3io.GetItemsInput{AttributeNames: []string{"__name", "n1", "n2", "n3", "n4"}}
Expand Down Expand Up @@ -609,7 +609,7 @@ func (kvSuite *KvTestSuite) TestNullColumnWrite() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

input := v3io.GetItemsInput{AttributeNames: []string{"__name", "n1", "n2"}}
Expand Down Expand Up @@ -733,7 +733,7 @@ func (kvSuite *KvTestSuite) TestRequestSpecificColumns() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

time.Sleep(3 * time.Second) // Let DB sync
Expand Down Expand Up @@ -773,7 +773,7 @@ func (kvSuite *KvTestSuite) TestRequestSpecificColumnsWithKey() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

time.Sleep(3 * time.Second) // Let DB sync
Expand Down Expand Up @@ -814,7 +814,7 @@ func (kvSuite *KvTestSuite) TestDeleteWithFilter() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

kvSuite.T().Log("delete")
Expand Down Expand Up @@ -862,7 +862,7 @@ func (kvSuite *KvTestSuite) TestRequestSystemAttrs() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

time.Sleep(3 * time.Second) // Let DB sync
Expand Down Expand Up @@ -899,7 +899,7 @@ func (kvSuite *KvTestSuite) TestNonExistingColumns() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

kvSuite.T().Log("read")
Expand Down Expand Up @@ -1063,7 +1063,7 @@ func (kvSuite *KvTestSuite) TestUpdateExpressionWithNullValues() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

// Second Phase: Update existing rows with null values
Expand Down Expand Up @@ -1096,7 +1096,7 @@ func (kvSuite *KvTestSuite) TestUpdateExpressionWithNullValues() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

input := v3io.GetItemsInput{AttributeNames: []string{"__name", "n1", "n2", "n3", "n4"}}
Expand Down Expand Up @@ -1174,7 +1174,7 @@ func (kvSuite *KvTestSuite) TestWritePartitionedTable() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

iter := frame.IterRows(true)
Expand Down Expand Up @@ -1222,7 +1222,7 @@ func (kvSuite *KvTestSuite) TestWritePartitionedTableWithMultiplePartitions() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

iter := frame.IterRows(true)
Expand Down Expand Up @@ -1271,7 +1271,7 @@ func (kvSuite *KvTestSuite) TestWritePartitionedBadPartitionColumns() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().Error(err, "expected error for table %v, but finished successfully", table)
}

Expand Down Expand Up @@ -1317,7 +1317,7 @@ func (kvSuite *KvTestSuite) TestWritePartitionedTableWithNullValues() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

expected := map[string]string{
Expand Down Expand Up @@ -1370,7 +1370,7 @@ func (kvSuite *KvTestSuite) TestUpdateExpressionWithCondition() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

// Second Phase: Update existing rows with condition
Expand Down Expand Up @@ -1399,7 +1399,7 @@ func (kvSuite *KvTestSuite) TestUpdateExpressionWithCondition() {
err = appender.Add(frame)
kvSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
kvSuite.Require().NoError(err)

input := v3io.GetItemsInput{AttributeNames: []string{"__name", "nums", "bools"}}
Expand Down
2 changes: 1 addition & 1 deletion test/stream_integration_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ func (streamSuite *StreamTestSuite) TestAll() {
err = appender.Add(frame)
streamSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
streamSuite.Require().NoError(err)

time.Sleep(3 * time.Second) // Let DB sync
Expand Down
16 changes: 8 additions & 8 deletions test/tsdb_integration_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ func (tsdbSuite *TsdbTestSuite) TestAll() {
err = appender.Add(frame)
tsdbSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
tsdbSuite.Require().NoError(err)

time.Sleep(3 * time.Second) // Let DB sync
Expand Down Expand Up @@ -199,7 +199,7 @@ func (tsdbSuite *TsdbTestSuite) TestRegressionIG14560() {
err = appender.Add(frame)
tsdbSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
tsdbSuite.Require().NoError(err)

time.Sleep(3 * time.Second) // Let DB sync
Expand Down Expand Up @@ -261,7 +261,7 @@ func (tsdbSuite *TsdbTestSuite) TestAllStringMetric() {
err = appender.Add(frame)
tsdbSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
tsdbSuite.Require().NoError(err)

time.Sleep(3 * time.Second) // Let DB sync
Expand Down Expand Up @@ -322,7 +322,7 @@ func (tsdbSuite *TsdbTestSuite) TestDeleteWithTimestamp() {
err = appender.Add(frame)
tsdbSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
tsdbSuite.Require().NoError(err)

tsdbSuite.T().Log("delete")
Expand Down Expand Up @@ -377,7 +377,7 @@ func (tsdbSuite *TsdbTestSuite) TestDeleteWithRelativeTime() {
err = appender.Add(frame)
tsdbSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
tsdbSuite.Require().NoError(err)

tsdbSuite.T().Log("delete")
Expand Down Expand Up @@ -431,7 +431,7 @@ func (tsdbSuite *TsdbTestSuite) TestDeleteWithRFC3339Time() {
err = appender.Add(frame)
tsdbSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
tsdbSuite.Require().NoError(err)

tsdbSuite.T().Log("delete")
Expand Down Expand Up @@ -487,7 +487,7 @@ func (tsdbSuite *TsdbTestSuite) TestDeleteAll() {
err = appender.Add(frame)
tsdbSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
tsdbSuite.Require().NoError(err)

tsdbSuite.T().Log("delete")
Expand Down Expand Up @@ -534,7 +534,7 @@ func (tsdbSuite *TsdbTestSuite) TestDeleteAllSamplesButNotTable() {
err = appender.Add(frame)
tsdbSuite.Require().NoError(err)

err = appender.WaitForComplete(3 * time.Second)
err = appender.WaitForComplete(10 * time.Second)
tsdbSuite.Require().NoError(err)

tsdbSuite.T().Log("delete")
Expand Down

0 comments on commit ee86c8c

Please sign in to comment.