wait longer time for checking job status

lyft · Feb 15, 2023 · a047c75 · a047c75
1 parent c828f0c
commit a047c75
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/integ/job_cancellation_test.go b/integ/job_cancellation_test.go
@@ -163,11 +163,17 @@ func (s *IntegSuite) TestCancelledJobWithoutSavepoint(c *C) {
 	c.Assert(err, IsNil)
 
 	// wait a bit
-	time.Sleep(1 * time.Second)
 
-	job = s.Util.GetJobOverview(currApp)
-	c.Assert(job["status"], Equals, "CANCELED")
+	counter := 0
+	for counter < 120 {
+		time.Sleep(1 * time.Second)
+
+		job = s.Util.GetJobOverview(currApp)
+		log.Infof("job status: %s", job["status"])
+		counter++
+	}
 
+	c.Assert(job["status"], Equals, "CANCELED")
 	newApp, err := s.Util.Update(config.Name, func(app *v1beta1.FlinkApplication) {
 		app.Spec.Image = NewImage
 	})