Skip to content

Commit

Permalink
change order of status check and fail
Browse files Browse the repository at this point in the history
  • Loading branch information
sethsaperstein-lyft committed May 3, 2023
1 parent d004ec2 commit cdc027b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions integ/checkpoint_failure_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,11 +23,11 @@ func failingJobTest(s *IntegSuite, c *C, testName string, causeFailure func()) {
c.Assert(s.Util.CreateFlinkApplication(config), IsNil,
Commentf("Failed to create flink application"))

c.Assert(s.Util.WaitForPhase(config.Name, v1beta1.FlinkApplicationRunning, v1beta1.FlinkApplicationDeployFailed), IsNil)

// Cause it to fail
causeFailure()

c.Assert(s.Util.WaitForPhase(config.Name, v1beta1.FlinkApplicationRunning, v1beta1.FlinkApplicationDeployFailed), IsNil)

// wait a bit for it to start failing
time.Sleep(5 * time.Second)

Expand Down

0 comments on commit cdc027b

Please sign in to comment.