Fix integration tests.

temporalio · May 4, 2020 · b6466e8 · b6466e8
1 parent 5f7230d
commit b6466e8
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/test/activity_test.go b/test/activity_test.go
@@ -56,7 +56,7 @@ func newActivities() *Activities {
 }
 
 func (a *Activities) RetryTimeoutStableErrorActivity() error {
-	time.Sleep(time.Second * 3)
+	time.Sleep(1 * time.Second)
 	return errFailOnPurpose
 }
 

diff --git a/test/integration_test.go b/test/integration_test.go
@@ -434,7 +434,7 @@ func (ts *IntegrationTestSuite) TestLargeQueryResultError() {
 	ts.Error(err)
 
 	ts.IsType(&serviceerror.QueryFailed{}, err)
-	ts.Equal("query result size (3000046) exceeds limit (2000000)", err.Error())
+	ts.Equal("query result size (3000027) exceeds limit (2000000)", err.Error())
 	ts.Nil(value)
 }
 

diff --git a/test/workflow_test.go b/test/workflow_test.go
@@ -434,12 +434,14 @@ func (w *Workflows) ConsistentQueryWorkflow(ctx workflow.Context, delay time.Dur
 
 func (w *Workflows) RetryTimeoutStableErrorWorkflow(ctx workflow.Context) ([]string, error) {
 	ao := workflow.ActivityOptions{
-		ScheduleToStartTimeout: time.Second * 2,
-		StartToCloseTimeout:    time.Second * 6,
+		ScheduleToStartTimeout: 1 * time.Second,
+		StartToCloseTimeout:    2 * time.Second,
+		ScheduleToCloseTimeout: 10 * time.Second,
 		RetryPolicy: &temporal.RetryPolicy{
-			InitialInterval:    time.Second,
+			InitialInterval:    1 * time.Second,
 			BackoffCoefficient: 1.0,
-			MaximumInterval:    time.Second,
+			MaximumInterval:    1 * time.Second,
+			MaximumAttempts:    3,
 		},
 	}
 	ctx = workflow.WithActivityOptions(ctx, ao)