diff --git a/internal/controllers/control/cassandratask_controller_test.go b/internal/controllers/control/cassandratask_controller_test.go index 3dc95304..9e722fd4 100644 --- a/internal/controllers/control/cassandratask_controller_test.go +++ b/internal/controllers/control/cassandratask_controller_test.go @@ -235,7 +235,7 @@ func waitForTaskFailed(taskKey types.NamespacedName) *api.CassandraTask { err := k8sClient.Get(context.TODO(), taskKey, emptyTask) Expect(err).ToNot(HaveOccurred()) - return emptyTask.Status.CompletionTime == nil + return emptyTask.Status.Failed > 0 }, time.Duration(5*time.Second)).Should(BeTrue()) return emptyTask }