Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
  • Loading branch information
nkubala committed Mar 26, 2019
1 parent cf94831 commit 8df1fb7
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions integration/rpc_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ func TestEventLogRPC(t *testing.T) {
if attempts < connectionRetries {
attempts++
t.Logf("waiting for connection...")
time.Sleep(3 * time.Second)
time.Sleep(waitTime)
continue
}
t.Fatalf("error retrieving event log: %v\n", err)
Expand Down Expand Up @@ -231,7 +231,6 @@ func TestGetStateRPC(t *testing.T) {
defer ctxCancel()

// try a few times and wait around until we see the build is complete, or fail.
attempts = 0
success := false
var grpcState *proto.State
for i := 0; i < stateRetries; i++ {
Expand All @@ -240,7 +239,7 @@ func TestGetStateRPC(t *testing.T) {
success = true
break
}
time.Sleep(1 * time.Second)
time.Sleep(waitTime)
}
if !success {
// max attempts exceeded, log errors
Expand All @@ -263,7 +262,7 @@ func retrieveRPCState(ctx context.Context, t *testing.T, client proto.SkaffoldSe
if attempts < connectionRetries {
attempts++
t.Logf("waiting for connection...")
time.Sleep(3 * time.Second)
time.Sleep(waitTime)
continue
}
t.Fatalf("error retrieving state: %v\n", err)
Expand Down Expand Up @@ -307,7 +306,7 @@ func TestGetStateHTTP(t *testing.T) {
success = true
break
}
time.Sleep(1 * time.Second)
time.Sleep(waitTime)
}
if !success {
// max attempts exceeded, log errors
Expand Down

0 comments on commit 8df1fb7

Please sign in to comment.