maxmustermann/pulumi
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Disable ConcurrentUpdateError test (#7953)

Browse source 
* Better logging from ConcurrentUpdateError test

* Disable the test
This commit is contained in:
Anton Tayanovskyy 2021-10-04 17:31:31 +00:00 committed by GitHub
parent 8208191795
commit 836b410911
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 23 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
sdk/go/auto/errors_test.go
View file

@ -28,6 +28,10 @@ import (
)
func TestConcurrentUpdateError(t *testing.T) {
// TODO[pulumi/pulumi#8122] - investigate underlying sporadic 404 error
t.Skip("disabled as flaky and resource-intensive")
n := 50
ctx := context.Background()
pName := "conflict_error"
sName := fmt.Sprintf("int_test%d", rangeIn(10000000, 99999999))
@ -50,7 +54,7 @@ func TestConcurrentUpdateError(t *testing.T) {
c := make(chan error)
// parallel updates to cause conflict
for i := 0; i < 50; i++ {
for i := 0; i < n; i++ {
go func() {
_, err := s.Up(ctx)
c <- err
@ -58,11 +62,16 @@ func TestConcurrentUpdateError(t *testing.T) {
}
conflicts := 0
var otherErrors []error
for i := 0; i < 50; i++ {
for i := 0; i < n; i++ {
err := <-c
if IsConcurrentUpdateError(err) {
conflicts++
if err != nil {
if IsConcurrentUpdateError(err) {
conflicts++
} else {
otherErrors = append(otherErrors, err)
}
}
}
@ -74,8 +83,16 @@ func TestConcurrentUpdateError(t *testing.T) {
t.FailNow()
}
// should have at least one conflict
assert.Greater(t, conflicts, 0)
if len(otherErrors) > 0 {
t.Logf("Concurrent updates incurred %d non-conflict errors, including:", len(otherErrors))
for _, err := range otherErrors {
t.Error(err)
}
}
if conflicts == 0 {
t.Errorf("Expected at least one conflict error from the %d concurrent updates, but got none", n)
}
}
func TestInlineConcurrentUpdateError(t *testing.T) {