We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8d6418d commit 29b355aCopy full SHA for 29b355a
1 file changed
test/integration_test.go
@@ -4303,8 +4303,10 @@ func (ts *IntegrationTestSuite) testUpdateOrderingCancel(cancelWf bool) {
4303
}()
4304
}
4305
4306
- // The server does not support admitted updates, so we send the update in a separate goroutine
4307
- time.Sleep(5 * time.Second)
+ // The server does not support admitted updates, so we send the update in a separate goroutine.
+ // Keep this shorter than the activity's ScheduleToCloseTimeout (5s) so the new worker
4308
+ // has time to execute activities before they time out.
4309
+ time.Sleep(2 * time.Second)
4310
// Now create a new worker on that same task queue to resume the work of the
4311
// workflow
4312
nextWorker := worker.New(ts.client, ts.taskQueueName, worker.Options{})
0 commit comments