Fix tests

goadesign · Oct 13, 2024 · 9945b2c · 9945b2c
1 parent 6d8af76
commit 9945b2c
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/streaming/options/options_test.go b/streaming/options/options_test.go
@@ -159,7 +159,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -170,7 +170,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -181,7 +181,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      10,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -192,7 +192,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 				Topic:          "foo",
 			},
 		},
@@ -204,7 +204,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 				TopicPattern:   "foo*",
 			},
 		},
@@ -216,7 +216,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     10,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -227,7 +227,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "foo",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -238,7 +238,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    fmt.Sprintf("%d-0", date.UnixMilli()),
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 			},
 		},
 		{
@@ -249,7 +249,7 @@ func TestSinkOptions(t *testing.T) {
 				MaxPolled:      1000,
 				BufferSize:     1000,
 				LastEventID:    "$",
-				AckGracePeriod: 30 * time.Second,
+				AckGracePeriod: 20 * time.Second,
 				NoAck:          true,
 			},
 		},