You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by ha...@apache.org on 2022/04/19 06:51:37 UTC

[skywalking-banyandb] 01/01: Increase time range to fix flaky testing

This is an automated email from the ASF dual-hosted git repository.

hanahmily pushed a commit to branch patch-liaison
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git

commit ec361ba701a03ec3a51201dd9d64bc0098b043da
Author: Gao Hongtao <ha...@gmail.com>
AuthorDate: Tue Apr 19 06:48:03 2022 +0000

    Increase time range to fix flaky testing
    
    Signed-off-by: Gao Hongtao <ha...@gmail.com>
---
 banyand/liaison/grpc/measure_test.go | 2 +-
 banyand/liaison/grpc/stream_test.go  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/banyand/liaison/grpc/measure_test.go b/banyand/liaison/grpc/measure_test.go
index f54a172..b25b8a7 100644
--- a/banyand/liaison/grpc/measure_test.go
+++ b/banyand/liaison/grpc/measure_test.go
@@ -127,7 +127,7 @@ func (p *preloadMeasureService) PreRun() error {
 func queryMeasureCriteria(baseTs time.Time) *measurev1.QueryRequest {
 	return pbv1.NewMeasureQueryRequestBuilder().
 		Metadata("sw_metric", "service_cpm_minute").
-		TimeRange(baseTs.Add(-1*time.Minute), baseTs.Add(1*time.Minute)).
+		TimeRange(baseTs.Add(-10*time.Minute), baseTs.Add(10*time.Minute)).
 		TagProjection("default", "id").
 		Build()
 }
diff --git a/banyand/liaison/grpc/stream_test.go b/banyand/liaison/grpc/stream_test.go
index 269f9c7..994639d 100644
--- a/banyand/liaison/grpc/stream_test.go
+++ b/banyand/liaison/grpc/stream_test.go
@@ -182,7 +182,7 @@ func queryStreamCriteria(baseTs time.Time) *streamv1.QueryRequest {
 		Limit(10).
 		Offset(0).
 		Metadata("default", "sw").
-		TimeRange(baseTs.Add(-1*time.Minute), baseTs.Add(1*time.Minute)).
+		TimeRange(baseTs.Add(-10*time.Minute), baseTs.Add(10*time.Minute)).
 		Projection("searchable", "trace_id").
 		Build()
 }